common

Documentation

Index

• func ConfigTopic(name string, partitions int, replication int) kafka.TopicConfig
• func GetKafkaWriter(topic string) *kafka.Writer
• type Topics

Functions

func ConfigTopic

func ConfigTopic(name string, partitions int, replication int) kafka.TopicConfig

func GetKafkaWriter

func GetKafkaWriter(topic string) *kafka.Writer

Types

type Topics

type Topics struct {
	Itens []kafka.TopicConfig
}