client

Documentation

Index

• type KafkaClient
  • func NewKafkaClient(config *sarama.Config, brokers []string) KafkaClient

Types

type KafkaClient

type KafkaClient interface {
	ListTopics() ([]*models.Topic, error)
	CreateTopic(name string, partitions int32, replication int16) error
	DeleteTopic(name string) error
	DescribeTopic(name string) (*models.TopicDesc, error)
	ListNodes() ([]*models.Node, error)
	ListGroups() ([]*models.Group, error)
	DescribeGroup(name string) (*models.GroupDesc, error)
}

func NewKafkaClient

func NewKafkaClient(config *sarama.Config, brokers []string) KafkaClient