testkafka

Documentation

Index

• func CreateCluster(t testing.TB, numPartitions int32, topicName string, opts ...Opt) (*kfake.Cluster, string)
• func CreateClusterWithoutCustomConsumerGroupsSupport(t testing.TB, numPartitions int32, topicName string, opts ...Opt) (*kfake.Cluster, string)
• func CreateProduceResponseError(version int16, topic string, partition int32, err *kerr.Error) *kmsg.ProduceResponse
• type Opt
  • func WithSASLPlain(username, password string) Opt

Functions

func CreateCluster

func CreateCluster(t testing.TB, numPartitions int32, topicName string, opts ...Opt) (*kfake.Cluster, string)

CreateCluster returns a fake Kafka cluster for unit testing.

func CreateClusterWithoutCustomConsumerGroupsSupport

func CreateClusterWithoutCustomConsumerGroupsSupport(t testing.TB, numPartitions int32, topicName string, opts ...Opt) (*kfake.Cluster, string)

func CreateProduceResponseError

func CreateProduceResponseError(version int16, topic string, partition int32, err *kerr.Error) *kmsg.ProduceResponse

CreateProduceResponseError returns a kmsg.ProduceResponse containing err for the input topic and partition.

Types

type Opt

type Opt func() []kfake.Opt

func WithSASLPlain

func WithSASLPlain(username, password string) Opt

WithSASLPlain enables SASL plain authentication in the Kafka fake server, expecting the input username and password credentials.