NewAckSource creates an instance of AckSource.

NewWriter creates a new instance of Writer.

AckSource represents an object that processes SampleGroups received from the Kafka message bus.

AckSourceConfig represents the configuration of an AckSource object.

DefaultConverter represents an oject has encapsulates the default Convert method.

Writer represents an object that encapsulates the behavior of a Kafka producter.

WriterConfig represents the configuration of a Writer object.

Converter is an interface that wraps the Convert method.