- is duplicated by
-
KAFKA-1330 Implement subscribe(TopicPartition...partitions) and pool(timeout) in the consumer
-
- Resolved
-
-
KAFKA-1331 Add ability to commit offsets to the new consumer
-
- Resolved
-