entity

Documentation

Index

• type KafkaConfig
• type TopicZkInfo

Types

type KafkaConfig

type KafkaConfig struct {
	BrokerServers string
	Config        *sarama.Config
	GroupID       string
	TopicPrefix   string
}

type TopicZkInfo

type TopicZkInfo struct {
	Business  string   `json:"business"`
	TopicName string   `json:"topicName"`
	Workers   []string `json:"workers"`
}