utils

Documentation

Index

• Constants
• func FindContainer(d *appsv1.Deployment, containerName string) *corev1.Container
• func TopicName(separator, namespace, name string) string
• type KafkaConfig
  • func GetKafkaConfig(configMap map[string]string) (*KafkaConfig, error)

Constants

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
)

Functions

func FindContainer

func FindContainer(d *appsv1.Deployment, containerName string) *corev1.Container

func TopicName

func TopicName(separator, namespace, name string) string

Types

type KafkaConfig

type KafkaConfig struct {
	Brokers             []string
	MaxIdleConns        int32
	MaxIdleConnsPerHost int32
}

func GetKafkaConfig

func GetKafkaConfig(configMap map[string]string) (*KafkaConfig, error)

GetKafkaConfig returns the details of the Kafka cluster.