kafka

type ConsumeErrorHandler func(topic string, partition int32, cause error)

type ConsumeHandler func(ctx context.Context, value []byte, meta Meta) (err error)

type Consumer interface {
	Listen(ctx context.Context) (err error)
	Shutdown(ctx context.Context)
}

type ConsumerOptions struct {
	Log logs.Logger

	Config configs.ConsumerConfig
}

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

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

type Header struct {
	Key   string `json:"key" avro:"key"`
	Value []byte `json:"value" avro:"value"`
}

type Headers []Header

type Meta struct {
	Topic           string
	Headers         Headers
	Key             []byte
	Partition       int32
	Offset          int64
	Time            time.Time
	ProducerEpoch   int16
	ProducerId      int64
	LeaderEpoch     int32
	TimestampType   TimestampType
	IsTransactional bool
	IsControl       bool
}

type Option func(options *Options)

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

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

type ProducerMessage struct {
	Topic   string  `json:"topic" avro:"topic"`
	Key     []byte  `json:"key" avro:"key"`
	Body    []byte  `json:"body" avro:"body"`
	Headers Headers `json:"headers" avro:"headers"`
}

type TimestampType int8

type TopicPartitionKey struct {
	Topic     string
	Partition int32
}