Expand description
Source side: a consumer on the source cluster that emits ReplicatedRecords
and snapshots all partition positions as a [SourceOffset].
Structsยง
- Source
Consumer - A [
Source] implementation backed by a Kafka consumer on the source cluster.