We are calling commitOffsets after every message consumption.  It looks to be 
~60% slower, with 29 partitions.  If a single KafkaStream thread is from a 
connector, and there are 29 partitions, then commitOffsets sends 29 offset 
updates, correct?  Are these offset updates batched in one send to zookeeper?

thanks,
rob

Reply via email to