[
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)