avroregistrytest

Documentation

Index

• func Register(ctx context.Context, t T, x interface{}, topic string) error
• type T

Functions

func Register

func Register(ctx context.Context, t T, x interface{}, topic string) error

Register an avro type in a registry for a particular topic and then delete the subject at the end of the test.

The following environment variables can be used to configure the connection parameters:

• $KAFKA_REGISTRY_ADDR The Kafka registry address in host:port form. If this is empty, localhost:8084 will be used.

This requires go1.14 or higher

Types

type T

type T interface {
	Cleanup(f func())
	Errorf(f string, a ...interface{})
}

T represents a test (the usual implementation being *testing.T).