Versions in this module Expand all Collapse all v0 v0.1.12 Sep 26, 2022 Changes in this version + type ConsumerGroup struct + func MustKafkaConsumer(c *KafkaConsumerConf) *ConsumerGroup + func (c *ConsumerGroup) Cleanup(sarama.ConsumerGroupSession) error + func (c *ConsumerGroup) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error + func (c *ConsumerGroup) Group() string + func (c *ConsumerGroup) RegisterHandlers(topic string, cb MessageHandlerF) + func (c *ConsumerGroup) Setup(sarama.ConsumerGroupSession) error + func (c *ConsumerGroup) Start() + func (c *ConsumerGroup) Stop() + func (c *ConsumerGroup) Topics() []string + type KafkaConsumerConf struct + Brokers []string + Group string + Topics []string + type KafkaProducerConf struct + Brokers []string + Topic string + type MessageHandlerF func(ctx context.Context, key string, value []byte) + type Producer struct + func GetCachedMQClient(c *KafkaProducerConf) *Producer + func MustKafkaProducer(c *KafkaProducerConf) *Producer + func (p *Producer) Close() (err error) + func (p *Producer) SendMessage(ctx context.Context, key string, value []byte) (partition int32, offset int64, err error) + func (p *Producer) Topic() string
Go to main page