# Functions
NewSCRAMClientGeneratorFn is a SCRAM client generator function for sarama.Config.
NewSink creates a new Kafka sink.
NewSinkConfig creates a new SinkConfig.
NewSource creates a new Kafka stream source.
NewSourceConfig creates a new Kafka source configuration.
# Constants
CommitAuto represents automatic commit strategy.
CommitBoth represents commit strategy that uses both CommitAuto and CommitManual.
CommitManual represents manual commit strategy.
# Variables
NilDecoder is a decoder that always returns a nil, no matter the input.
# Structs
ByteDecoder represents a byte decoder.
ByteEncoder represents a byte encoder.
PartitionOffset represents the position in the stream of a message.
SCRAMClient represents a SASL/SCRAM client.
Sink represents a Kafka streams sink.
SinkConfig represents the configuration of a Sink.
Source represents a Kafka stream source.
SourceConfig represents the configuration for a Kafka stream source.
StringDecoder represents a string decoder.
StringEncoder represents a string encoder.
# Type aliases
CommitStrategy represents commit strategy for source commiting.
DecoderFunc is an adapter allowing to use a function as a decoder.
EncoderFunc is an adapter allowing to use a function as an encoder.
Metadata represents an the kafka topic metadata.