Versions in this module Expand all Collapse all v1 v1.0.1 Feb 16, 2024 Changes in this version + type Message struct + Headers map[string]string + Key []byte + Offset int64 + Partition int32 + Topic string + Value []byte + type Reader struct + func New(t *testing.T, c sarama.Consumer) *Reader + func (r *Reader) Read(ctx context.Context, timeout time.Duration, topic string) *sarama.ConsumerMessage + func (r *Reader) Stop() error