Documentation
¶
Index ¶
Constants ¶
View Source
const ( CLUSTER_NETWORK_NAME = "kafka-cluster" ZOOKEEPER_PORT = "2181" KAFKA_BROKER_PORT = "9092" KAFKA_CLIENT_PORT = "9093" ZOOKEEPER_IMAGE = "confluentinc/cp-zookeeper:5.2.1" KAFKA_IMAGE = "confluentinc/cp-kafka:5.2.1" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KafkaCluster ¶
type KafkaCluster struct {
// contains filtered or unexported fields
}
func NewKafkaCluster ¶
func NewKafkaCluster() *KafkaCluster
func (*KafkaCluster) GetKafkaHost ¶
func (kc *KafkaCluster) GetKafkaHost() string
func (*KafkaCluster) StartCluster ¶
func (kc *KafkaCluster) StartCluster()
Source Files
Click to show internal directories.
Click to hide internal directories.