# Functions
New instantiates new kafka github consumer instance.
WithBackoff sets backoff duration.
WithDialTimeout sets dial timeout.
WithKafkaBrokers sets kafka brokers list.
WithLogger sets logger.
WithMaxRetries sets max retries value.
WithPartition sets partition.
WithProcessMessageFunc sets the message processor.
WithReadTimeout sets read timeout.
WithSaramaConsumerFactoryFunc sets a custom factory function for creating Sarama consumers.
WithTopic sets topic name to consume.
WithWriteTimeout sets write timeout.
# Constants
defaults.
defaults.
defaults.
defaults.
defaults.
defaults.
# Interfaces
KafkaConsumer defines kafka consumer behaviours.
# Type aliases
Option represents option function type.
ProcessMessageFunc is a factory function for callers.
SaramaConsumerFactoryFunc is a factory function.