Philip Nee created KAFKA-14247:
----------------------------------
Summary: Implement EventHandler interface and DefaultEventHandler
Key: KAFKA-14247
URL: https://issues.apache.org/jira/browse/KAFKA-14247
Project: Kafka
Issue Type: Sub-task
Components: consumer
Reporter: Philip Nee
Assignee: Philip Nee
The polling thread uses events to communicate with the background thread. The
events send to the background thread are the {_}Requests{_}, and the events
send from the background thread to the polling thread are the {_}Responses{_}.
Here we have an EventHandler interface and DefaultEventHandler implementation.
The implementation uses two blocking queues to send events both ways. The two
methods, add and poll allows the client, i.e., the polling thread, to retrieve
and add events to the handler.
PR: https://github.com/apache/kafka/pull/12663
--
This message was sent by Atlassian Jira
(v8.20.10#820010)