You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flume.apache.org by "Hari Shreedharan (JIRA)" <ji...@apache.org> on 2015/01/07 02:28:35 UTC

[jira] [Commented] (FLUME-2562) Metrics for Flafka components

    [ https://issues.apache.org/jira/browse/FLUME-2562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14267137#comment-14267137 ] 

Hari Shreedharan commented on FLUME-2562:
-----------------------------------------

+1. This looks good. I will run tests later today and commit this.

> Metrics for Flafka components
> -----------------------------
>
>                 Key: FLUME-2562
>                 URL: https://issues.apache.org/jira/browse/FLUME-2562
>             Project: Flume
>          Issue Type: Improvement
>            Reporter: Gwen Shapira
>            Assignee: Gwen Shapira
>         Attachments: FLUME-2562.1.patch
>
>
> Kafka source, sink and channel should have metrics. This will help us track down possible issues or performance problems.
> Here are the metrics I came up with:
> kafka.next.time - Time spent waiting for events from Kafka (source and channel)
> kafka.send.time - Time spent sending events (channel and sink) 
> kafka.commit.time - Time spent committing (source and channel)
> events.sent - Number of events sent to Kafka (sink and channel)
> events.read - Number of events read from Kafka (channel and source)
> events.rollback - Number of event rolled back (channel) or number of rollback calls (sink)
> kafka.empty - Number of times backing off due to empty kafka topic (source)



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)