Categorygithub.com/devchain-network/cauldroninternalkafkacpkafkaconsumer
package
0.1.7
Repository: https://github.com/devchain-network/cauldron.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
12
Dependents
1
Files
376 SLOC

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

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