Description
This involves adding basic fetch functionality (equivalent to SimpleConsumer) to the new consumer. Effectively:
1) Implement subscribe(TopicPartition...partitions) and unsubscribe(TopicPartition...partitions).
2) Implement pool(timeout).
3) Add memory management to the consumer.
Attachments
Attachments
Issue Links
- blocks
-
KAFKA-1331 Add ability to commit offsets to the new consumer
-
- Resolved
-
- duplicates
-
KAFKA-1760 Implement new consumer client
-
- Resolved
-