Versions in this module Expand all Collapse all v0 v0.0.7 Aug 4, 2023 v0.0.6 Mar 29, 2022 Changes in this version + type DefaultConsumer struct + func (consumer *DefaultConsumer) Cleanup(sarama.ConsumerGroupSession) error + func (consumer *DefaultConsumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error + func (consumer *DefaultConsumer) Setup(sarama.ConsumerGroupSession) error + type Kafka struct + Admin sarama.ClusterAdmin + AsyncProducer sarama.AsyncProducer + Client sarama.Client + GroupMap sync.Map + OffsetManager sarama.OffsetManager + SyncProducer sarama.SyncProducer + func New(ctx context.Context, confStr string) (*Kafka, error) + func (k *Kafka) Close() + func (k *Kafka) ConsumerGroup(groupID string, topics string, handler sarama.ConsumerGroupHandler) error + func (k *Kafka) Consumes(topic string, handle func(*sarama.ConsumerMessage)) error + func (k *Kafka) SendSyncMessage(message *sarama.ProducerMessage) error
Go to main page