kafka

Documentation

Index

• func DefaultConfig(clientId string) *sarama.Config
• func EnsureTopics(client sarama.Client, topics Topics) error
• func NewSchemaRegistry(kafkaClient sarama.Client, topic string, replicationFactor int16) (schema.Registry, error)
• type Topic
• type Topics
• type TopicsFunc

Functions

func DefaultConfig

func DefaultConfig(clientId string) *sarama.Config

func EnsureTopics

func EnsureTopics(client sarama.Client, topics Topics) error

func NewSchemaRegistry

func NewSchemaRegistry(kafkaClient sarama.Client, topic string, replicationFactor int16) (schema.Registry, error)

Types

type Topic

type Topic struct {
	Name              string
	NumPartitions     int32
	ReplicationFactor int16
	Config            map[string]*string
}

type Topics

type Topics []Topic

type TopicsFunc

type TopicsFunc func(replicationFactor int16) Topics