api

Documentation

Index

• type ConsumerGroup
• type KafkaDataSource
• type Message
• type MessageHandlerFunc

Types

type ConsumerGroup

type ConsumerGroup struct {
	Name      string
	State     string
	Consumers int
}

type KafkaDataSource

type KafkaDataSource interface {
	Init()
	GetTopics() ([]string, error)
	GetContexts() ([]string, error)
	GetContext() string
	SetContext(contextName string) error
	GetConsumerGroups() ([]ConsumerGroup, error)
	ConsumeTopic(topicName string, handleMessage MessageHandlerFunc) error
}

type Message

type Message struct {
	Key    string
	Value  string
	Offset int64
}

type MessageHandlerFunc

type MessageHandlerFunc func(msg Message)