kafkatest

Nov 29, 2023

Changes in this version

+ type TestClient struct

+ Topic string

+ func NewTestClient[EventType any](t *testing.T, ctx context.Context, cfg TestClientConfig) *TestClient[EventType]

+ func (c *TestClient[EventType]) Client() *kafka.Client

+ func (c *TestClient[EventType]) ConsumeEvent(t *testing.T, ctx context.Context) EventType

+ func (c *TestClient[EventType]) PublishEvents(t *testing.T, ctx context.Context, events ...EventType)

+ func (c *TestClient[EventType]) PublishMessages(t *testing.T, ctx context.Context, msgs ...kafka.Message)

+ func (c *TestClient[EventType]) Reader() *kafka.Reader

+ func (c *TestClient[EventType]) Registry() *TestRegistry[EventType]

+ func (c *TestClient[EventType]) TopicMessageCount(t *testing.T, ctx context.Context) int64

+ func (c *TestClient[EventType]) Writer() *kafka.Writer

+ type TestClientConfig struct

+ KafkaBrokerHostPort string

+ NumTopicPartitions int

+ SchemaRegistryHostPort string

+ type TestRegistry struct

+ func NewTestRegistry[EventType any](t *testing.T, ctx context.Context, hostPort string, subject string) *TestRegistry[EventType]

+ func (r *TestRegistry[EventType]) Decode(t *testing.T, ctx context.Context, data []byte) EventType

+ func (r *TestRegistry[EventType]) Encode(t *testing.T, ctx context.Context, event EventType) []byte