kafka

Documentation

Index

• Constants
• type KafkaClient
  • func NewKafkaClient(uri *url.URL, topicType string) (KafkaClient, error)

Constants

const (
	TimeSeriesTopic = "timeseriestopic"
	EventsTopic     = "eventstopic"
)

Types

type KafkaClient

type KafkaClient interface {
	Name() string
	Stop()
	ProduceKafkaMessage(msgData interface{}) error
}

func NewKafkaClient

func NewKafkaClient(uri *url.URL, topicType string) (KafkaClient, error)