Versions in this module Expand all Collapse all v1 v1.0.1 Feb 16, 2024 v1.0.0 Jan 25, 2024 Changes in this version + type Client struct + func NewClient(t *testing.T, addr []string) *Client + func (c *Client) Consume(ctx context.Context, topic string) *sarama.ConsumerMessage + func (c *Client) Produce(topic string, value []byte, headers ...sarama.RecordHeader) + func (c *Client) ProduceWithKey(topic string, key, value []byte, headers ...sarama.RecordHeader)