如何从一开始就订阅

Question

I am trying to write a Kafka Consumer with GroupId foo, which Subscribes to a certain topic and reads from the very beginning (even if there is a previous offset). I tried to use Subscribe with the rebalance callback, but it never seems to be called (have set the go.application setting).

Is there any example how one would make this work?

---

EDIT: Added more details

Answer 1

We now went with setting enable.auto.commit to false. This way, there will be no offset stored and we consume from the beginning on every run just fine.