You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Rafał Chmielewski (Jira)" <ji...@apache.org> on 2021/03/15 22:01:00 UTC
[jira] [Updated] (KAFKA-12469) The topic names in the metrics do
not retain their format when extracting through JMX.
[ https://issues.apache.org/jira/browse/KAFKA-12469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Rafał Chmielewski updated KAFKA-12469:
--------------------------------------
Description:
I have topic names that have a period in the name:
product.order
product.offering.price
However, for the metrics issued by JMX by a program that is a consumer of Kafka messages, the dots are replaced with an underscore:
kafka.consumer<type=consumer-fetch-manager-metrics, client-id=consumer-export-4, topic=product_offering_price, partition=1><>records-lead
This creates a problem if I want to calculate the customer's lag in relation to the number of messages on Kafka.
But for the producer, this problem doesn't occur:
kafka.producer<type=producer-topic-metrics, client-id=bss.data.verification.pi_1, topic=product.offering.price><>record-send-total
As a consumer I use Akka Alpakka. But I think it's using Apache library to connect to Kafka and report metrics via JMX.
was:
I have topic names that have a period in the name:
product.order
product.offering.price
However, for the metrics issued by JMX by a program that is a consumer of Kafka messages, the dots are replaced with an underscore:
kafka.consumer<type=consumer-fetch-manager-metrics, client-id=consumer-export-4, topic=product_offering_price, partition=1><>records-lead
But for the producer, this problem doesn't occur:
kafka.producer<type=producer-topic-metrics, client-id=bss.data.verification.pi_1, topic=product.offering.price><>record-send-total
As a consumer I use Akka Alpakka. But I think it's using Apache library to connect to Kafka and report metrics via JMX.
> The topic names in the metrics do not retain their format when extracting through JMX.
> --------------------------------------------------------------------------------------
>
> Key: KAFKA-12469
> URL: https://issues.apache.org/jira/browse/KAFKA-12469
> Project: Kafka
> Issue Type: Bug
> Components: metrics
> Reporter: Rafał Chmielewski
> Priority: Major
>
> I have topic names that have a period in the name:
> product.order
> product.offering.price
>
> However, for the metrics issued by JMX by a program that is a consumer of Kafka messages, the dots are replaced with an underscore:
> kafka.consumer<type=consumer-fetch-manager-metrics, client-id=consumer-export-4, topic=product_offering_price, partition=1><>records-lead
>
> This creates a problem if I want to calculate the customer's lag in relation to the number of messages on Kafka.
>
> But for the producer, this problem doesn't occur:
> kafka.producer<type=producer-topic-metrics, client-id=bss.data.verification.pi_1, topic=product.offering.price><>record-send-total
>
> As a consumer I use Akka Alpakka. But I think it's using Apache library to connect to Kafka and report metrics via JMX.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)