Documentation ¶
Index ¶
Constants ¶
View Source
const ( BrokerConfigMapKey = "bootstrapServers" MaxIdleConnectionsKey = "maxIdleConns" MaxIdleConnectionsPerHostKey = "maxIdleConnsPerHost" KafkaChannelSeparator = "." // DefaultNumPartitions defines the default number of partitions DefaultNumPartitions = 1 // DefaultReplicationFactor defines the default number of replications DefaultReplicationFactor = 1 DefaultMaxIdleConns = 1000 DefaultMaxIdleConnsPerHost = 100 )
Variables ¶
This section is empty.
Functions ¶
Types ¶
type KafkaConfig ¶
func GetKafkaConfig ¶
func GetKafkaConfig(configMap map[string]string) (*KafkaConfig, error)
GetKafkaConfig returns the details of the Kafka cluster.
Click to show internal directories.
Click to hide internal directories.