# Packages
Package mocks implements a simple Kafka client and consumer for testing purposes.
# Functions
NewOffsetSeeker instantiates an offsetManager.
ProvideConn is called by Wire to construct this package's logical.Dialect implementation.
ProvideConveyorConfig is called by Wire.
ProvideEagerConfig is a hack to move up the evaluation of the user script so that the options callbacks can set any non-script-related CLI flags.
ProvideSchemaWatchConfig is called by Wire.
Start creates a Kafka logical replication loop using the provided configuration.
# Variables
Set is used by Wire.
# Structs
Config contains the configuration necessary for creating a replication connection.
Conn encapsulates all wire-connection behavior.
Consumer represents a Kafka consumer.
Kafka is a kafka logical replication loop.
SASLConfig defines the SASL parameters.
# Interfaces
Conveyor exposes the methods used by the kafka connector to deliver mutations, in batches, to the destination.
OffsetSeeker finds offsets within Kafka topics.
# Type aliases
EagerConfig is a hack to get Wire to move userscript evaluation to the beginning of the injector.