WithKafkaAutoOffsetReset sets the auto offset reset policy.

WithBrokers sets Kafka brokers.

WithKafkaClientID sets Kafka client ID for producer.

WithKafkaConsumerGroupID sets Kafka consumer group ID.

WithKafkaFetchMinBytes sets the fetch minimum bytes.

WithKafkaFetchWaitMaxMs sets the fetch wait max time.

WithKafkaHeartbeatIntervalMs sets the heartbeat interval.

WithKafkaMaxPollIntervalMs sets the max poll interval.

WithKafkaRetryBackoffMs sets the retry backoff time.

WithKafkaSchemaRegistryURL sets the schema registry URL.

WithKafkaSessionTimeoutMs sets the session timeout.

DefaultConfig holds the default Kafka settings.

KafkaConsumerConfig holds Kafka consumer settings.

KafkaProducerConfig holds Kafka producer settings.

SchemaRegistryConfig holds Schema Registry settings.

Option is a functional option for configuring Kafka.