Closed YadhuPrakash closed 5 months ago
Librdkafka emits topic level stats like so:
{ "name": "rdkafka#producer-1", "client_id": "rdkafka", "ts": 5016483227792, "brokers": {}, "topics": { "test": { "topic": "test", "batchsize": {}, "batchcnt": {}, "partitions": {} } } }, }
This update allows users to subscribe to topic level stats as a metric with: RdKafkaMetric.new(:gauge, :topics, 'topics.batchcnt.avg', %w[batchcnt avg])
RdKafkaMetric.new(:gauge, :topics, 'topics.batchcnt.avg', %w[batchcnt avg])
Related issue: https://github.com/karafka/waterdrop/issues/495
All committers have signed the CLA.
Summary:
Librdkafka emits topic level stats like so:
This update allows users to subscribe to topic level stats as a metric with:
RdKafkaMetric.new(:gauge, :topics, 'topics.batchcnt.avg', %w[batchcnt avg])
Related issue: https://github.com/karafka/waterdrop/issues/495