kafka

Documentation

Index

• type ConfigEntry
• type FlowKafka
  • func NewFlowKafka(c *ServiceConfig) FlowKafka
• type Metadata
• type ServiceConfig
• type Topic

Types

type ConfigEntry

type ConfigEntry struct {
	Name      string
	Value     string
	ReadOnly  bool
	Default   bool
	Sensitive bool
}

ConfigEntry represents topic configuration.

type FlowKafka

type FlowKafka interface {
	CreateTopic(topic string, numPartitions int, replicationFactor int, retentionMs string) error
	DeleteTopic(topic string) error
	DescribeTopic(topic string) (*Topic, error)
	Produce(topic string, msg []byte) error
}

FlowKafka is an interface representing operations that can be executed with Kafka Cluster.

func NewFlowKafka

func NewFlowKafka(c *ServiceConfig) FlowKafka

NewFlowKafka create new instance of service

type Metadata

type Metadata struct {
	Topics []*Topic
}

Metadata represents topics details.

type ServiceConfig

type ServiceConfig struct {
	BootstrapBroker string
	// contains filtered or unexported fields
}

type Topic

type Topic struct {
	Name     string         `json:"name,omitempty"`
	Configs  []*ConfigEntry `json:"configs,omitempty"`
	ErrorMsg *string        `json:"errorMsg,omitempty"`
}

Topic represents kafka topic.