Skip to main content

Module common

Module common 

Source

Structs§

KafkaClientSasl
The SASL configurations for kafka client.
KafkaClientTls
The TLS configurations for kafka client.
KafkaConnectionConfig
The connection configurations for kafka clients.
KafkaTopicConfig
Topic configurations for kafka clients.

Enums§

KafkaClientSaslConfig

Constants§

DEFAULT_AUTO_PRUNE_INTERVAL
Default interval for auto WAL pruning.
DEFAULT_AUTO_PRUNE_LOGICAL_DELETE
Default mode for auto WAL pruning.
DEFAULT_AUTO_PRUNE_PARALLELISM
Default limit for concurrent auto pruning tasks.
DEFAULT_BACKOFF_CONFIG
The default backoff config for kafka client.
DEFAULT_CHECKPOINT_TRIGGER_SIZE
Default checkpoint trigger size.
DEFAULT_FLUSH_TRIGGER_SIZE
Default size of WAL to trigger flush.
DEFAULT_PERIODIC_CHECKPOINT_PERSIST_INTERVAL
Default interval to periodically persist remote WAL checkpoints.
DEFAULT_REGION_FLUSH_TRIGGER_INTERVAL
Default interval for remote WAL region flush trigger.
DEFAULT_TOPIC_LATEST_OFFSET_FETCH_INTERVAL
Default interval for fetching latest Kafka topic offsets.