flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rmetzger <...@git.apache.org>
Subject [GitHub] flink pull request #2236: [FLINK-4186] Use Flink metrics to report Kafka met...
Date Wed, 13 Jul 2016 08:52:34 GMT
GitHub user rmetzger opened a pull request:

    https://github.com/apache/flink/pull/2236

    [FLINK-4186] Use Flink metrics to report Kafka metrics

    We were using Flink's accumulators in the past to report the Kafka metrics.
    With this change, we'll use the new metrics of Flink.
    
    I'm now also exposing the current offset of each topic partition through the metrics.

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/rmetzger/flink flink4186

Alternatively you can review and apply these changes as the patch at:

    https://github.com/apache/flink/pull/2236.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #2236
    
----
commit 234c549b6046d33ff8545661435ddb97b453bb2e
Author: Robert Metzger <rmetzger@apache.org>
Date:   2016-07-12T11:55:29Z

    [FLINK-4186] Use Flink metrics to report Kafka metrics
    
    This commit also adds monitoring for the current offset

----


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

Mime
View raw message