feat(kafka): add MessageBroker/Kafka/Cluster/{id}/Produce|Consume/{topic} metrics - #4044

Open

shashank-reddy-nr wants to merge 21 commits into

newrelic:mainfrom

shashank-reddy-nr:feat/kafka-cluster-id

Commits on Aug 5, 2026

feat(kafka): add MessageBroker/Kafka/Cluster/{id}/Topic/{topic} metrics
shashank-reddy-nr
committed
075c9ab
refactor(kafka): address code review feedback on cluster metrics
shashank-reddy-nr
committed
5e0d138
refactor(kafka): move cluster-id caches into ConstructorSubscriber
shashank-reddy-nr
committed
43b2579
fix(lint): add JSDoc param descriptions and fix arrow/arg-newline lint errors
shashank-reddy-nr
committed
3699056
test(kafka): add unit tests for auth mechanism compatibility in ConstructorSubscriber
shashank-reddy-nr
committed
ad861fa
fix(kafka): enforce TTL on cluster-id cache and prevent TTL bypass
shashank-reddy-nr
committed
3fa461c
chore(kafka): increase cluster ID cache TTL from 30 min to 1 hour
shashank-reddy-nr
committed
0255bfc
fix(kafka): prevent admin client socket leak on cluster-ID fetch timeout
shashank-reddy-nr
committed
77d8f65
fix(kafkajs): fix lint and versioned CI failures for cluster-ID metrics
shashank-reddy-nr
committed
08eea64
feat: gate Kafka cluster metrics behind opt-in feature flag
shashank-reddy-nr
committed
7dfb67a
test: register kafka_cluster_metrics in feature flag test used list
shashank-reddy-nr
committed
d52141a
test(kafkajs): enable kafka_cluster_metrics flag in unit and versioned tests
shashank-reddy-nr
committed
8fa0ddc
test(kafkajs): add unit tests for record-cluster-produce-metrics and record-data-metrics
shashank-reddy-nr
committed
fc2f52e
ci: retrigger for flaky cpu.test.js integration failure
shashank-reddy-nr
committed
30e6ea3
test(kafkajs): cover #refreshAndRecordProduceMetrics and eachBatch cluster-metrics branches
shashank-reddy-nr
committed
690ca74
test(kafkajs): fix lint errors in cluster-metrics unit tests
shashank-reddy-nr
committed
720daec
perf(kafkajs): optimize cluster ID capture to avoid extra AdminClient connection
shashank-reddy-nr
committed
3b84613
fix(kafkajs): guard cluster produce metrics against malformed send() args
shashank-reddy-nr
committed
d1adeed

Commits on Aug 7, 2026

fix(kafkajs): align cluster metric name with Nodes metric shape
shashank-reddy-nr
committed
f933db5

Navigation Menu

Uh oh!

feat(kafka): add MessageBroker/Kafka/Cluster/{id}/Produce|Consume/{topic} metrics - #4044

feat(kafka): add MessageBroker/Kafka/Cluster/{id}/Produce|Consume/{topic} metrics#4044
shashank-reddy-nr wants to merge 21 commits into
newrelic:mainfrom
shashank-reddy-nr:feat/kafka-cluster-id

Commits on Aug 5, 2026

feat(kafka): add MessageBroker/Kafka/Cluster/{id}/Topic/{topic} metrics

refactor(kafka): address code review feedback on cluster metrics

refactor(kafka): move cluster-id caches into ConstructorSubscriber

fix(lint): add JSDoc param descriptions and fix arrow/arg-newline lint errors

test(kafka): add unit tests for auth mechanism compatibility in ConstructorSubscriber

fix(kafka): enforce TTL on cluster-id cache and prevent TTL bypass

chore(kafka): increase cluster ID cache TTL from 30 min to 1 hour

fix(kafka): prevent admin client socket leak on cluster-ID fetch timeout

fix(kafkajs): fix lint and versioned CI failures for cluster-ID metrics

feat: gate Kafka cluster metrics behind opt-in feature flag

test: register kafka_cluster_metrics in feature flag test used list

test(kafkajs): enable kafka_cluster_metrics flag in unit and versioned tests

test(kafkajs): add unit tests for record-cluster-produce-metrics and record-data-metrics

ci: retrigger for flaky cpu.test.js integration failure

test(kafkajs): cover #refreshAndRecordProduceMetrics and eachBatch cluster-metrics branches

test(kafkajs): fix lint errors in cluster-metrics unit tests

perf(kafkajs): optimize cluster ID capture to avoid extra AdminClient connection

fix(kafkajs): guard cluster produce metrics against malformed send() args

Commits on Aug 7, 2026

fix(kafkajs): align cluster metric name with Nodes metric shape

Commits on Aug 17, 2026

fix(kafkajs): force metadata fetch before reading clusterId in versioned test

ci: retrigger for flaky action-download rate limit (503/429 on jwalton/gh-docker-logs)