package
0.1.7
Repository: https://github.com/devchain-network/cauldron.git
Documentation: pkg.go.dev

# 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

# Structs

Consumer represents kafa consumer setup.

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