kafka

Documentation

Index

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

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, logger logger.Logger, errorLogger logger.Logger) Client