i implemented high level consumer code manual offset in local have 1 question ask if suppose if not commit message there logic read message again without restarting consumer again.i able message if restarting consumer how without restarting consumer.
kafka high level consumer(upto kafka 0.8.2) not provide fine grained control on offsets. hence can not go , read earlier offset ( without restarting).
in latest kafka release 0.9.0 have updated consumer api. new consumer api has option seek. using seek call can seek particular offset @ point in time.
Comments
Post a Comment