Consumer.SetOffset() uses the new rdkafka.Consumer.StoreOffsets(), which will store the offsets (related to the consumer config enable.auto.offset.store: false)
the client no longer runs the periodic c.commitOffsets() loop. The goroutine and its relevant synchronization were completely removed. This is replaced with the enable.auto.commit: true consumer config.
Consumer.Run() now after subscribing to the topics just waits for the ctx.Done()
the -i flag is removed, replaced by the consumer config auto.commit.interval.ms
Consumer.SetOffset()
uses the newrdkafka.Consumer.StoreOffsets()
, which will store the offsets (related to the consumer configenable.auto.offset.store: false
)c.commitOffsets()
loop. The goroutine and its relevant synchronization were completely removed. This is replaced with theenable.auto.commit: true
consumer config.Consumer.Run()
now after subscribing to the topics just waits for thectx.Done()
-i
flag is removed, replaced by the consumer configauto.commit.interval.ms
Closes #32