GitHub user wyzssw opened a pull request:
https://github.com/apache/kafka/pull/207
support commit offset after consumed
Kafka Of Original Version do not support "commit offset after
consuming",when kafka.consumer.ConsumerIterator[K, V].next() return a
MessageAndMeta
GitHub user wyzssw opened a pull request:
https://github.com/apache/kafka/pull/206
let kafka support "commit offset after consuming"
Kafka Of Original Version do not support "commit offset after
consuming",when kafka.consumer.ConsumerIterator[K