# Functions
New creates a new tester instance.
NewMockTopicManager creates a new topic manager mock.
WithHeaders sets kafka headers to use when emitting to kafka.
# Structs
MockTopicManager mimicks the behavior of the real topic manager.
QueueTracker tracks message offsets for each topic for convenient 'expect message x to be in topic y' in unit tests.
Tester mimicks kafka for complex highlevel testing of single or multiple processors/views/emitters.
# Interfaces
T abstracts the interface we assume from the test case.
# Type aliases
EmitOption defines a configuration option for emitting messages.