reader

Documentation

Index

• type Message
• type Reader
  • 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

Types

type Message

type Message struct {
	Topic     string            `json:"topic"`
	Partition int32             `json:"partition"`
	Offset    int64             `json:"offset"`
	Value     []byte            `json:"value"`
	Key       []byte            `json:"key,omitempty"`
	Headers   map[string]string `json:"headers,omitempty"`
}

type Reader

type Reader struct {
	// contains filtered or unexported fields
}

func New

func New(t *testing.T, c sarama.Consumer) *Reader

func (*Reader) Read

func (r *Reader) Read(ctx context.Context, timeout time.Duration, topic string) *sarama.ConsumerMessage

func (*Reader) Stop

func (r *Reader) Stop() error