Jay Kreps created KAFKA-1316: -------------------------------- Summary: Refactor Sender Key: KAFKA-1316 URL: https://issues.apache.org/jira/browse/KAFKA-1316 Project: Kafka Issue Type: Sub-task Reporter: Jay Kreps Assignee: Jay Kreps
Currently most of the logic of the producer I/O thread is in Sender.java. However we will need to do a fair number of similar things in the new consumer. Specifically: - Track in-flight requests - Fetch metadata - Manage connection lifecycle It may be possible to refactor some of this into a helper class that can be shared with the consumer. This will require some detailed thought. -- This message was sent by Atlassian JIRA (v6.2#6252)