Module enumerator 

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 🔒

is_expected_no_group_poll_error 🔒

sync_resolved_partitions 🔒

Drops cached start offsets of partitions that are no longer present and returns the partitions whose start offset still has to be resolved.

Type Aliases

KafkaAdmin 🔒

KafkaConsumer 🔒