Hi Shafaq,
"Yes" to your first question.
For second question that depends on what would you like to do when your
request's offset is not valid. This is possible, for example, if your logs
gets deleted according to retention policy and your last committed offset
in ZK is within that deleted range.
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
a
