Hi, I wanted to control the commitOffset signal to ZK from High-level kafka consumer. This will enable to process the message by consumer and incase of failure the offset is not moved.
If I do auto.commit.enable= false and then use commitallOffset Api of high-level consumer, is that way to achieve it? Also "auto.offset.reset"="smallest" need to be set inorder for consumer to consume messages which are already published by broker. Is that correct? Please comment. thanks! -- Kind Regards, Shafaq
