kafka

Documentation

Index

• Constants
• func GrantsToACLStrings(dn string, grants []v1alpha1.UserTopicGrant) []string
• func LabelsForKafka(name string) map[string]string

Constants

const (
	// AllBrokerServiceTemplate template for Kafka headless service
	AllBrokerServiceTemplate = "%s-all-broker"
	// HeadlessServiceTemplate template for Kafka headless service
	HeadlessServiceTemplate = "%s-headless"
)

Functions

func GrantsToACLStrings

func GrantsToACLStrings(dn string, grants []v1alpha1.UserTopicGrant) []string

GrantsToACLStrings converts a user DN and a list of topic grants to raw strings for a CR status

func LabelsForKafka

func LabelsForKafka(name string) map[string]string

LabelsForKafka returns the labels for selecting the resources belonging to the given kafka CR name.