Module common

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_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.