[ 
https://issues.apache.org/jira/browse/KAFKA-12469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882931#comment-17882931
 ] 

Iacopo Talevi commented on KAFKA-12469:
---------------------------------------

We are experiencing the same problem. In our case, the topic is called 
‘user.test.sviluppi’, in the producer metrics (on the right in the attached 
image) the name is correct while in the consumer metrics (on the left in the 
attached image) the dots are replaced by underscores. In our architecture we 
use Dynatrace agent to capture the metrics and this renaming does not allow us 
to link producer and consumer because for Dynatrace they integrate different 
topics. The behaviour can also be replicated with JConsole and with clients of 
various versions (see attached image).

!JConsole - Kafka Client.png!

> 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
>            Priority: Major
>         Attachments: JConsole - Kafka Client.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)

Reply via email to