# Functions
ConfigFromFile loads the Kafka multiplexer configuration from the specified file.
InitMultiplexer initialize and returns new kafka multiplexer based on the supplied config file.
InitMultiplexerWithConfig initialize and returns new kafka multiplexer based on the supplied mux configuration.
Mock returns mock of Multiplexer that can be used for testing purposes.
NewMultiplexer creates new instance of Kafka Multiplexer.
ToBytesMsgChan allows to receive ConsumerMessage through channel.
ToBytesProducerChan allows to receive ProducerMessage through channel.
ToBytesProducerErrChan allows to receive ProducerMessage through channel.
# Constants
DefAddress default kafka address/port (if not specified in config).
DefPartition is used if no specific partition is set.
OffsetNewest is head offset which will be assigned to the new message produced to the partition.
OffsetOldest is oldest offset available on the partition.
# Structs
BytesConnectionFields is an entity that provides access to shared producers/consumers of multiplexer.
BytesConnectionStr represents connection built on hash-mode multiplexer.
BytesManualConnectionStr represents connection built on manual-mode multiplexer.
Config holds the settings for kafka multiplexer.
KafkaMock for the tests.
Multiplexer encapsulates clients to kafka cluster (SyncProducer, AsyncProducer (both of them with 'hash' and 'manual' partitioner), consumer).
ProtoConnection represents connection built on hash-mode multiplexer.
ProtoConnectionFields is an entity that provides access to shared producers/consumers of multiplexer.
ProtoManualConnection represents connection built on manual-mode multiplexer.
# Interfaces
BytesConnection is interface for multiplexer with dynamic partitioner.
BytesManualConnection is interface for multiplexer with manual partitioner.
BytesPublisher allows to publish a message of type []bytes into messaging system.
Connection is interface for multiplexer with dynamic partitioner.
ManualConnection is interface for multiplexer with manual partitioner.
# Type aliases
ConsumerFactory produces a consumer for the selected topics in a specified consumer group.