org.apache.kafka.common.requests.OffsetCommitRequest.
-Suren
Joel/All,
The SimpleConsumer constructor requires a specific host and port.
Can this be any broker?
If it needs to be a specific broker, for 0.8.2, should this be the offset
coordinator? For 0.8.1, does it matter?
-Suren
On Thursday, February 19, 2015 10:43 AM, Joel Koshy jjkosh
. :-)
It looked like instantiating a SimpleConsumer just to reset offsets on restart
was a viable option, while continuing to use the High Level Consumer for our
normal operations. Not sure if there is a better way that is compatible across
0.8.1 and 0.8.2.
-Suren
On Thursday, February 19, 2015 10:25
Haven't used either one now. Sounds like 0.8.2.1 will help.
We are using the High Level Consumer generally but are thinking to use the
SimpleConsumer on failure recovery to set the offsets.
Is that the recommended approach for this use case?
Thanks.
-Suren
On Thursday, February 19, 2015 9
Reading offsets looks like it's compatible across 0.8.1 and 0.8.2.
However, we cannot use the update logic in ImportZkOffsets, since we want to
store offsets in the broker in 0.8.2.
It looks like SimpleConsumer.commitOffsets() would work with either version. Is
there a better way?
-Suren
