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

[jira] [Commented] (KAFKA-1730) add the doc for the new java producer in 0.8.2

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

Manikumar Reddy commented on KAFKA-1730:
----------------------------------------

just want to update new producer JMX metrics . Not sure where to update.

*MBean Name*: kafka.producer:type=producer-metrics,client-id=\[producerId\]
                   Ex: kafka.producer:type=producer-metrics,client-id=my-producer
||Attribute||Description||
|waiting-threads | The number of user threads blocked waiting for buffer memory to enqueue their records|
|buffer-total-bytes | The maximum amount of buffer memory the client can use (whether or not it is currently used).|
|buffer-available-bytes |The total amount of buffer memory that is not being used (either unallocated or in the free list).|
|bufferpool-wait-time |The fraction of time an appender waits for space allocation.|
|batch-size-avg  |The average number of bytes sent per partition per-request.|
|batch-size-max  |The max number of bytes sent per partition per-request.|
|compression-rate-avg| The average compression rate of record batches.|
| record-queue-time-avg  |The average time in ms record batches spent in the  record accumulator.|
| record-queue-time-max  |The maximum time in ms record batches spent in the record accumulator|.
|request-latency-avg |The average request latency in ms |
|request-latency-max |The maximum request latency in ms|
|record-send-rate| The average number of records sent per second.|
| records-per-request-avg |The average number of records per request.|
| record-retry-rate |The average per-second number of retried record sends|
|record-error-rate |The average per-second number of record sends that resulted in errors|
|record-size-max |The maximum record size|
|record-size-avg  |The average record size|
|requests-in-flight |The current number of in-flight requests awaiting a response.|
| metadata-age |The age in seconds of the current producer metadata being used.|
|connection-close-rate | Connections closed per second in the window.|
| connection-creation-rate  |New connections established per second in the window.|
|network-io-rate |The average number of network operations (reads or writes) on all connections per second.|
|outgoing-byte-rate |The average number of outgoing bytes sent per second to all servers.|
| request-rate |The average number of requests sent per second.|
|request-size-avg |The average size of all requests in the window..|
|request-size-max |The maximum size of any request sent in the window.|
|incoming-byte-rate |Bytes/second read off all sockets|
|response-rate |Responses received sent per second.|
| select-rate| Number of times the I/O layer checked for new I/O to perform per second|
|io-wait-time-ns-avg |The average length of time the I/O thread spent waiting for a socket ready for reads or writes in nanoseconds.|
| io-wait-ratio | The fraction of time the I/O thread spent waiting.|
| io-time-ns-avg| The average length of time for I/O per select call in nanoseconds.|
| io-ratio| The fraction of time the I/O thread spent doing I/O|
|connection-count |The current number of active connections.|


*MBean Name* : kafka.producer:type=producer-node-metrics,client-id=\[producerId\],node-id=\[nodeId\]
                    Ex: kafka.producer:type=producer-node-metrics,client-id=my-producer,node-id=node-0

||Attribute||Description||
|outgoing-byte-rate ||
|request-rate |The average number of requests sent per second.|
| request-size-avg |The average size of all requests in the window..|
| request-size-max |The maximum size of any request sent in the window.|
| incoming-byte-rate |The average number of responses received per second.|
|request-latency-avg ||
| request-latency-max||
| response-rate ||

*MBean Name* = kafka.producer:type=producer-topic-metrics,client-id=\[producerId\],topic=\[topicName\]
                      Ex: kafka.producer:type=producer-topic-metrics,client-id=my-producer,topic=TOPIC1

||Attribute||Description||
| record-send-rate||
| byte-rate||
|compression-rate||
| record-retry-rate||
|record-error-rate||

> add the doc for the new java producer in 0.8.2
> ----------------------------------------------
>
>                 Key: KAFKA-1730
>                 URL: https://issues.apache.org/jira/browse/KAFKA-1730
>             Project: Kafka
>          Issue Type: Sub-task
>    Affects Versions: 0.8.2
>            Reporter: Jun Rao
>            Priority: Blocker
>




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