CloseReader attempts to close the provided reader and logs the error if it fails.

CloseWriter attempts to close the provided writer and logs the error if it fails.

Consume consumes a message from the reader with the provided handler function.

CreateDialer returns a Kafka dialer for the Kafka Go library, which includes the TLS configuration and the Sasl mechanism to connect to the managed Kafka.

CreateSaslMechanism returns a Sasl mechanism that Kafka Go requires for setting up the connection.

CreateTLSConfig returns a TLS configuration.

CreateTransport returns a kafka transport that is memoized since it can be used concurrently.

GetReader returns a Kafka reader configured with the specified settings.

GetWriter returns a Kafka writer configured with the specified settings.

Produce produces a message with the writer.

package level sharable kafka variables, safe to use concurrently.

Options is a struct for creating a reader/writer.

wrapping the reader/writer types we're using so we can change them under the hood in the future if necessary.

wrapper around the logger methods we need.