![]() |
Qore jni Module 2.4.0
|
The KafkaDataProvider module provides a data provider API for sending and receiving Kafka messages.
This data provider provides Kafka functionality with the Kafka
factory and data provider with the same name, supporting asynchronous Kafka events and messaging (class KafkaDataProvider).
These examples are with qdp
, the command-line interface to the Data Provider API.
qdp 'Kafka{xxx}/producer' send message 'xxx'
qdp 'Kafka{xxx}'/consumer ix