kafka

Jan 5, 2024

Changes in this version

+ type SinkResponseHandler interface

+ OnError func(ctx *SinkResponseHandlerContext)

+ OnSuccess func(ctx *SinkResponseHandlerContext)

+ type SinkResponseHandlerContext struct

+ Err error

+ Message *message.KafkaMessage

Jul 12, 2023

Changes in this version

+ type Client interface

+ CheckTopicIsCompacted func(topic string) error

+ CheckTopics func(topics []string) error

+ Consumer func(topic string, partition int, startOffset int64) *kafka.Reader

+ CreateCompactedTopic func(topic string, partition int, replicationFactor int) error

+ GetEndOffsets func(topic string, partitions []int) ([]kafka.PartitionOffsets, error)

+ GetPartitions func(topic string) ([]int, error)

+ Producer func() *kafka.Writer

+ func NewClient(config *config.Connector, logger logger.Logger, errorLogger logger.Logger) Client