THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Name | Description |
|---|---|
kafka.cluster:type=Partition,name=ProducerCountProducerIdCount,topic=<topic>,partition=<N> | The number of active transactional / idempotent producers that produced to topic <topic> partition <N>. |
kafka.server:type=ReplicaManager,name=ProducerCountProducerIdCount | The total number of active transactional / idempotent producers in the broker. |
Proposed Changes
Add the new metrics to the ReplicaManager and Partition classes correspondingly.
...
- No migration plan is needed because these metrics are new
Rejected Alternatives
Name the metric ProducerCount - may be misleading as the producers without producer ids are not counted.
Have 2 metrics IdempotentProducerCount and TransactionalProducerCount - currently we don't keep track which producer id is idempotent and which is transactional, adding that would add some complexity and potential runtime overhead, currently there doesn't seem to be a monitoring scenario that requires distinguishing between the two.