Hi,

Currently we are using 0.8.1 version of Kafka ?.

Does this ConsumerConenctor.commitOffset method commits all partitions for 
messages in iterator or only the offset of message that is currently consumed.

Please clarify as we are manually committing offsets and this would create 
bigger issue for us.

Thanks,

Balaji


Reply via email to