kafka

Documentation

Index

• Constants
• Variables
• func VerifyMessagesInTopic(client *kubernetes.Clientset, tracker *testlib.Tracker, ...) error
• func VerifyNumPartitionAndReplicationFactor(client *kubernetes.Clientset, tracker *testlib.Tracker, namespace string, ...) error
• type Config
• type ConsumerConfig

Constants

const (
	BootstrapServers = "my-cluster-kafka-bootstrap.kafka:9092"
)

Variables

var (
	BootstrapServersArr = []string{"my-cluster-kafka-bootstrap.kafka:9092"}
)

Functions

func VerifyMessagesInTopic

func VerifyMessagesInTopic(
	client *kubernetes.Clientset,
	tracker *testlib.Tracker,
	namespacedName types.NamespacedName,
	config *ConsumerConfig) error

func VerifyNumPartitionAndReplicationFactor

func VerifyNumPartitionAndReplicationFactor(
	client *kubernetes.Clientset,
	tracker *testlib.Tracker,
	namespace string,
	name string,
	config *Config) error

Types

type Config

type Config struct {
	BootstrapServers  string `required:"true" split_words:"true"`
	ReplicationFactor int16  `required:"true" split_words:"true"`
	NumPartitions     int32  `required:"true" split_words:"true"`
	Topic             string `required:"true" split_words:"true"`
}

type ConsumerConfig

type ConsumerConfig struct {
	BootstrapServers string `json:"bootstrapServers" required:"true" split_words:"true"`
	Topic            string `json:"topic" required:"true" split_words:"true"`
	IDS              string `json:"ids" required:"true" split_words:"true"`
	ContentMode      string `json:"contentMode" required:"true" split_words:"true"`
}