Categorygithub.com/ONSdigital/dp-kafka/v4interfaces
package
4.1.0
Repository: https://github.com/onsdigital/dp-kafka.git
Documentation: pkg.go.dev
Overview
Versions
2
Dependencies
2
Dependents
3
Files
49 SLOC

# Interfaces

Message represents a single kafka message.
No description provided by the author

# Type aliases

BrokerGenerator is a function that returns a sarama broker interface.
ConsumerGroupInitialiser is a function that returns a sarama consumer group interface.
ProducerInitialiser is a function that returns a sarama async producer interface.
SaramaAsyncProducer is an alias for sarama.AsyncProducer.
SaramaConsumerGroup is an alias for sarama.ConsumerGroup.
SaramaConsumerGroupClaim is an alias for sarama.ConsumerGroupClaim.
SaramaConsumerGroupSession is an alias for sarama.ConsumerGroupSession.