[KAFKA-18048] Consider to decouple AppEventHandler from ConsumerNetworkThread

• Type: Improvement
• Status: Open
• Priority: Minor
• Resolution: Unresolved
• Component/s: consumer
• Labels: consumer-threading-refactor
• Assignee: PoAn Yang
• Reporter: PoAn Yang
• Created: 20/Nov/24 10:46
• Updated: 29/Nov/24 16:34

Description

When implementing new JMX metrics in AsyncKafkaConsumer, we would like to encapsulate applicationEventQueue in ApplicationEventHandler, so we don't need to expose applicationEventQueue in ConsumerNetworkThread.

However, we start ConsumerNetworkThread in ApplicationEventHandler. This makes circular dependency. We can try to decouple these components, so ConsumerNetworkThread doesn't need to get application events from the queue directly.

ref: https://github.com/apache/kafka/pull/17199#discussion_r1849058419