Debezium Server 2.5.2.Final

Source: Azure Sql Server

Sink: Azure Event Hubs

What behaviour do you expect?

Snapshot not skipping records sent to Azure Event Hub

What behaviour do you see?

Snapshot skipping records sent to Azure Event Hub

Follow up ticket out of zulip discussion

https://debezium.zulipchat.com/#narrow/stream/348252-community-sqlserver/topic/Snapshot.20missing.20records.2C.20skips.20every.2079.2F80.20records

Seems like the record being added to the batch for processing, gets marked as processed, even it was never part of the batch.

https://github.com/debezium/debezium-server/blob/main/debezium-server-eventhubs/src/main/java/io/debezium/server/eventhubs/EventHubsChangeConsumer.java#L181

https://github.com/debezium/debezium-server/blob/main/debezium-server-eventhubs/src/main/java/io/debezium/server/eventhubs/BatchManager.java#L110

Not processed events should never be "lost".