Module kafka 

Kafka sink and compacted-topic checkpoint store.

Structs

KafkaCheckpointStore

Durable connector checkpoint store keyed by connector and source identity.

KafkaSink

At-least-once Kafka sink backed by an idempotent acks=all producer.

Constants

CHECKPOINT_TOPIC

Compacted Kafka topic holding the most recent source offset per connector.