risingwave_connector::source::kafka

Module enumerator

Source

Structs§

KafkaSplitEnumerator

Enums§

KafkaEnumeratorOffset

Statics§

SHARED_KAFKA_ADMIN
Admin client is short-lived, so we store Arc and sets a time-to-idle eviction policy.
SHARED_KAFKA_CONSUMER
Consumer client is shared, and the cache doesn’t manage the lifecycle, so we store Weak and no eviction.

Functions§

build_kafka_admin 🔒
build_kafka_client 🔒

Type Aliases§

KafkaAdmin 🔒
KafkaConsumer 🔒