package
0.3.0
Repository: https://github.com/xataio/pgstream.git
Documentation: pkg.go.dev

# Functions

New returns a kafka checkpointer that commits the message offsets to kafka by partition/topic on demand.
No description provided by the author

# Structs

Checkpointer is a kafka implementation of the wal checkpointer.
No description provided by the author

# Type aliases

No description provided by the author