ShivsundarR opened a new pull request, #20283:
URL: https://github.com/apache/kafka/pull/20283

   *What*
   https://issues.apache.org/jira/browse/KAFKA-18220
   
   - Currently, `AsyncConsumerMetrics` extends `KafkaConsumerMetrics`, but is 
being used both by `AsyncKafkaConsumer` and `ShareConsumerImpl`.
   
   - `ShareConsumerImpl` only needs the async consumer metrics(the metrics 
associated with the new consumer threading model).
   - This needs to be fixed, we are unnecessarily having `KafkaConsumerMetrics` 
as a parent class for `ShareConsumer` metrics.
   
   Fix : 
   - In this PR, we have removed the dependancy of `AsyncConsumerMetrics` on 
`KafkaConsumerMetrics` and made it an independent class which both 
`AsyncKafkaConsumer` and `ShareConsumerImpl` will use.
   - The "`asyncConsumerMetrics`" field represents the metrics associated with 
the new consumer threading model (like application event queue size, background 
queue size, etc).
   - The "`kafkaConsumerMetrics`" and "`kafkaShareConsumerMetrics`" fields 
denote the actual consumer metrics for `KafkaConsumer` and `KafkaShareConsumer` 
respectively.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Reply via email to