Hi,
how to pass an offset/message to the next member of a consumer group? i.e. if the current consumer process has been failed. Does consumer.pause()
instead of consumer.commit(msg)
solve it?
Hi,
how to pass an offset/message to the next member of a consumer group? i.e. if the current consumer process has been failed. Does consumer.pause()
instead of consumer.commit(msg)
solve it?