Hi,

Does anyone know how to batch fetch/commit the Kafka topic offsets using
the new Kafka 0.10 API?
When we were using Kafka 0.81, we used BlockingChannel to send
OffsetCommitRequest and OffsetFetchRequest to do it in batch from Zk.

However in 0.10, everything is built for single consumer based. If I used
the commited() or commitAsync() it is only for single consumer. I can not
do batch commit anymore which I believe will slow down the system as we
have hundred of partitions for each topic.

Thanks
Martin

Reply via email to