You are viewing an old version of this page. View the current version.

Compare with Current View Page History

Version 1 Next »

Status

Current state: Under Discussion

Discussion thread: here [Change the link from the KIP proposal email archive to your own email thread]

JIRA: here [Change the link from KAFKA-1 to your own ticket]

Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).

Motivation

KIP-664: Provide tooling to detect and abort hanging transactions provided tooling to get visibility into transactional and idempotent producers that the broker keeps track of.  This KIP proposes to add ProducerCount  metrics that enable easy monitoring of transactional and idempotent producer counts on the broker.

Public Interfaces

We propose adding 2 new broker metrics

NameDescription
kafka.cluster:type=Partition,name=ProducerCount,topic=<topic>,partition=<N> The number of active transactional / idempotent producers that produced to topic <topic> partition <N>. 
kafka.server:type=ReplicaManager,name=ProducerCount The total number of active transactional / idempotent producers in the broker

Proposed Changes

Add the new metrics to the ReplicaManager  and Partition classes correspondingly.

Compatibility, Deprecation, and Migration Plan

  • No migration plan is needed because these metrics are new


  • No labels