Reset consumer stored offset

[Randy Rodriguez Collado]

Hi,

Hope you are doing fine.

Our topic for debezium was deleted including the replication slot from which Debezium was reading. After the topic and the replication slot were recreated, our consumer have all of a sudden a lag of -22 million messages (Yes negative) is there a way to reset those to match the most recent messages? (We just want to have it start streaming from today, without considering the messages from the past)

I hope to hear back from you soon.

Regards,

Randy

[Gunnar Morling]

Easiest is to create the connector using a new name. Alternatively, see the FAQ for removing committed connector offsets:

    https://debezium.io/documentation/faq/#how_to_remove_committed_offsets_for_a_connector

--Gunnar