Module kafka

Modules

client_manager 🔒

consumer 🔒

high_watermark_manager 🔒

index 🔒

log_store

producer 🔒

util 🔒

worker 🔒

Structs

EntryImpl

Kafka Entry implementation.

GlobalIndexCollector

The GlobalIndexCollector struct is responsible for managing index entries across multiple providers.

NamespaceImpl

Kafka Namespace implementation.

Constants

DEFAULT_PARTITION

Functions

default_index_file