search

xataio / pgstream

PostgreSQL replication with DDL changes
http://www.xata.io
Apache License 2.0
349 stars 11 forks source link

Use the same kafka reader for fetching and committing messages #65

Closed eminano closed 3 months ago

eminano commented 3 months ago

This PR updates the kafka checkpointer and listener to use the same kafka reader. This will ensure the messages are fetched and committed by the same reader, which has shown to cause sporadic connection issues at startup when the reader connects to kafka, failing to receive any messages.