Versions in this module Expand all Collapse all v1 v1.0.0 Mar 7, 2024 Changes in this version + func NewKafkaReader(opts *NewKafkaReaderOptions) (*kafka.Reader, error) + func NewKafkaWriter(opts *NewKafkaWriterOptions) (*kafka.Writer, error) + func Subscribe(ctx context.Context, opts *NewKafkaReaderOptions, ...) error + func WriteMessage(ctx context.Context, writer *kafka.Writer, key []byte, value []byte, ...) error + type NewKafkaReaderOptions struct + Brokers []string + GroupID string + GroupTopics []string + Partition int + Password string + Topic string + Username string + type NewKafkaWriterOptions struct + BatchSize int + BatchTimeout time.Duration + Brokers []string + Password string + Topic string + Username string
Go to main page