KafkaClient
KafkaClient is a specialization of the MessageClient included in the Messaging-Engine Module module.
The KafkaClient connects to a Kafka broker and handles the publication as well as subscription of messages.
KafkaClient extends MessageClient and provides the following additional properties.
Name | Type | Description |
---|---|---|
servers |
Array of String | List of kafka brokers to connect to. Format: IP:PORT . E.g.: ‘localhost:9092’ |
Note: The consumer used in the implementation expects String-based message contents.