A set of components for messaging using the Kafka protocol.
Important points
- It contains the implementation of the components for working with messages: KafkaMessageQueue, KafkaConnectionResolver.
Packages
The module contains the following packages:
- Build - default Factory for creating components
- Connect - generate and resolve connection options
- Queues - message queue that creates, sends and receives messages
Use
Get the package from the Github repository:
go get -u github.com/pip-services4/pip-services4-go/tree/main/pip-services4-kafka-go@latest