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 🔒

Type Aliases

• KafkaAdmin 🔒
• KafkaConsumer 🔒