kafka

Documentation

Index

• type Client
  • func NewClient(config *config.Connector) Client
• type SinkResponseHandler
• type SinkResponseHandlerContext

Types

type Client

type Client interface {
	GetEndOffsets(topic string, partitions []int) ([]kafka.PartitionOffsets, error)
	GetPartitions(topic string) ([]int, error)
	CreateCompactedTopic(topic string, partition int, replicationFactor int) error
	Producer() *kafka.Writer
	Consumer(topic string, partition int, startOffset int64) *kafka.Reader
	CheckTopicIsCompacted(topic string) error
	CheckTopics(topics []string) error
}

func NewClient

func NewClient(config *config.Connector) Client

type SinkResponseHandler

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

type SinkResponseHandlerContext

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