Documentation ¶
Overview ¶
Package kafka provides a kafka broker using sarama cluster
Index ¶
- Variables
- func AsyncProducer(errors chan<- *sarama.ProducerError, successes chan<- *sarama.ProducerMessage) broker.Option
- func BrokerConfig(c *sarama.Config) broker.Option
- func ClusterConfig(c *sarama.Config) broker.Option
- func NewBroker(opts ...broker.Option) broker.Broker
- func SubscribeConfig(c *sarama.Config) broker.SubscribeOption
- func SubscribeContext(ctx context.Context) broker.SubscribeOption
Constants ¶
This section is empty.
Variables ¶
View Source
var ( DefaultBrokerConfig = sarama.NewConfig() DefaultClusterConfig = sarama.NewConfig() )
Functions ¶
func AsyncProducer ¶
func AsyncProducer(errors chan<- *sarama.ProducerError, successes chan<- *sarama.ProducerMessage) broker.Option
func SubscribeConfig ¶
func SubscribeConfig(c *sarama.Config) broker.SubscribeOption
func SubscribeContext ¶
func SubscribeContext(ctx context.Context) broker.SubscribeOption
SubscribeContext set the context for broker.SubscribeOption
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.