kfk

Documentation

Index

• Constants
• func DoInitConsumer(cfg *KafkaConfig) *kafka.Consumer
• func DoInitProducer(cfg *KafkaConfig) *kafka.Producer
• type KafkaConfig
  • func LoadJsonConfig() *KafkaConfig

Constants

const (
	INT32_MAX = 2147483647 - 1000
)

Functions

func DoInitConsumer

func DoInitConsumer(cfg *KafkaConfig) *kafka.Consumer

func DoInitProducer

func DoInitProducer(cfg *KafkaConfig) *kafka.Producer

Types

type KafkaConfig

type KafkaConfig struct {
	Topic            string `json:"topic"`
	Topic2           string `json:"topic2"`
	GroupId          string `json:"group.id"`
	BootstrapServers string `json:"bootstrap.servers"`
	SecurityProtocol string `json:"security.protocol"`
	SaslMechanism    string `json:"sasl.mechanism"`
	SaslUsername     string `json:"sasl.username"`
	SaslPassword     string `json:"sasl.password"`
}

func LoadJsonConfig

func LoadJsonConfig() *KafkaConfig

config should be a pointer to structure, if not, panic