kafka

type Client interface {
	GetPartitions(topic string) ([]int, error)
	Producer(completionHandler func(messages []kafka.Message, err error)) *kafka.Writer
	Consumer(topic string, partition int, startOffset int64) *kafka.Reader
	CheckTopic(topic string) error
}

type MetricsRecorder interface {
	RecordKafkaConnectorLatency(latencyMs int64)
	RecordBatchProduceLatency(latencyMs int64)
}

type RejectionLog struct {
	Topic string
	Value string
	Error string
	Key   []byte
}

type RejectionLogSinkResponseHandler struct {
	KafkaClient Client
	Writer      *kafka.Writer
	Topic       string
	Config      config.Kafka
}

type SinkResponseHandler interface {
	OnInit(ctx *SinkResponseHandlerInitContext)
	OnSuccess(ctx *SinkResponseHandlerContext)
	OnError(ctx *SinkResponseHandlerContext)
}

type SinkResponseHandlerContext struct {
	Message *message.KafkaMessage
	Err     error
}

type SinkResponseHandlerInitContext struct {
	KafkaClient Client
	Writer      *kafka.Writer
	Config      config.Kafka
}