client

Documentation

Index

• type KafkaClient
  • func NewKafkaClient(brokerAddress string) (KafkaClient, error)
• type KafkaError

Types

type KafkaClient

type KafkaClient interface {
	TopicExists(topicName string) (bool, *KafkaError)
	CreateTopic(topicName string) error
	Close() error
}

func NewKafkaClient

func NewKafkaClient(brokerAddress string) (KafkaClient, error)

type KafkaError

type KafkaError struct {
	GeneralError error
	KError       sarama.KError
}