Versions in this module Expand all Collapse all v0 v0.2.0 May 12, 2024 v0.1.0 Apr 27, 2024 Changes in this version + type Consumer struct + func NewConsumer(brokers []string, topic string, groupID string, opts ...Option) *Consumer + func (c *Consumer) Close() + func (c *Consumer) Consume(ctx context.Context, handle func(ctx context.Context, msg kafka.Message) error) + type ConsumerOption interface + Apply func(option) + type Option interface + Apply func(option) + func WithAuthentication(username string, password string) Option + type Producer struct + func NewProducer(brokers []string, topic string, opts ...Option) *Producer + func (p *Producer) Produce(ctx context.Context, message kafka.Message) error + type ProducerOption interface + Apply func(option)
Go to main page