...
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.