You have been redirected from an outdated version of the article. Below is the content available on this topic. To view the old article click here.

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.

Search results for "KafkaClient"

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.

MessageClient