Replaying Events From Kafka

[onerishabh]

Hey Team,

I'm running the connector as a Docker container. It would be nice if some pointers can be shared around if required how can I replay some events into Snowflake. I understand there is also some kind of watermarking that is done on Snowflake at the table channel level. I'm certain your response will be helpful to the wider community as well.

I have access to kafka cli on my container.

thanks!

[onerishabh]

Just for context; I have tried resetting offset for consumer group on kafka but that is not enough; need to also reset channel offset of snowflake as well using SYSTEM$SNOWPIPE_STREAMING_UPDATE_CHANNEL_OFFSET_TOKEN.

Concern if SYSTEM$SNOWPIPE_STREAMING_UPDATE_CHANNEL_OFFSET_TOKEN needs an exact offset number and can't be set to null making it harder for us to rewind channels.