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
• type AdminConfig
• 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

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