kafka

Documentation

Index

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

Functions

func VerifyMessagesInTopic

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

func VerifyNumPartitionAndReplicationFactor

func VerifyNumPartitionAndReplicationFactor(
	client kubernetes.Interface,
	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"`
}