Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KafkaBrokerInfo ¶
type KafkaBrokerInfo struct { ListenerSecurityProtocolMap map[string]string `json:"listener_security_protocol_map"` RawEndpoints []string `json:"endpoints"` Endpoints map[string]string JmxPort string Host string Timestamp string Port int Version int }
func (*KafkaBrokerInfo) ParseEndpoint ¶
func (k *KafkaBrokerInfo) ParseEndpoint()
type KafkaBrokers ¶
type KafkaBrokers struct { Timeout int // contains filtered or unexported fields }
func NewKafkaBrokers ¶
func NewKafkaBrokers(brokerEndpoints []string, timeout int, ca, cert, key string) (*KafkaBrokers, error)
type KafkaBrokersInfo ¶
type KafkaBrokersInfo []KafkaBrokerInfo
func (KafkaBrokersInfo) BrokerEndpoints ¶
func (ks KafkaBrokersInfo) BrokerEndpoints(listener string) []string
type Zookeeper ¶
type Zookeeper struct {
// contains filtered or unexported fields
}
func NewZookeeper ¶
func (*Zookeeper) BrokerList ¶
func (z *Zookeeper) BrokerList() (KafkaBrokersInfo, error)
Click to show internal directories.
Click to hide internal directories.