kafka

Documentation

Index

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

Functions

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