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