[
https://issues.apache.org/jira/browse/KAFKA-12469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17898748#comment-17898748
]
Jun Rao commented on KAFKA-12469:
---------------------------------
[~apoorvmittal10] : Thanks for the update.
[https://github.com/apache/kafka/pull/939] first introduced the replacement.
It's probably just to follow the replacement in Yammer metric used by the old
scala consumer. Since this replacement is only needed for Yammer reporter, we
could avoid the replacement in the client metrics.
> 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: consumer, metrics
> Reporter: Rafał Chmielewski
> Assignee: Apoorv Mittal
> Priority: Major
> Attachments: JConsole - Kafka Client.png, Screenshot 2024-11-12 at
> 21.35.59.png, image-2024-11-12-21-32-55-180.png
>
>
> 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.20.10#820010)
