The client package provides single purpose clients for publishing synchronous/asynchronous messages and for consuming selected topics.
The mux package uses these clients and allows to share their access to kafka brokers among multiple entities. This package also implements the generic messaging API defined in the parent package.
Minimal supported version of kafka is determined by sarama library - Kafka 0.10 and 0.9, although older releases are still likely to work.
If you don't have kafka installed locally you can use docker image for testing:
sudo docker run -p 2181:2181 -p 9092:9092 --name kafka --rm \
--env ADVERTISED_HOST=172.17.0.1 --env ADVERTISED_PORT=9092 spotify/kafka
Kafka plugin provides access to kafka brokers.
API
The plugin's API is documented at the end of doc.go.
Configuration
- Location of the Kafka configuration file can be defined either by command line flag
kafka-configor set viaKAFKA_CONFIGenv variable.
Status Check
- Kafka plugin has a mechanism to periodically check a connection status of the Kafka server.