kafka

Documentation

Index

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

Functions

func VerifyCommittedOffset

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

func VerifyConsumerGroupLag

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

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 AdminConfig

type AdminConfig struct {
	BootstrapServers string `json:"bootstrapServers" required:"true" split_words:"true"`
	Topic            string `json:"topic" required:"true" split_words:"true"`
	Group            string `json:"group" required:"true" split_words:"true"`
}

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"`
}