![]() |
Qore jni Module 2.6.0
|
Event-based data provider for Kafka events. More...
#include <KafkaConsumerDataProvider.qc.dox.h>
Public Member Methods | |
| hash< DataProvider::DataProviderInfo > | getStaticInfoImpl () |
| Returns data provider static info. | |
| void | stopEvents () |
| Called to stop generating events. | |
| hash< string, hash< DataProviderMessageInfo > > | getEventTypesImpl () |
| Returns a hash of all supported event types. | |
Public Member Methods inherited from KafkaDataProvider::KafkaDataProviderBase | |
| void | constructor (KafkaConnection conn) |
| Creates the object from a connection object. | |
Public Attributes | |
| const auto | ProviderInfo = ... |
| Provider info. | |
| const auto | ConstructorOptions = ... |
| Constructor options. | |
| const auto | EVENT_KAFKA_MESSAGE = ... |
| Kafka message event constant. | |
Event-based data provider for Kafka events.
| hash< string, hash< DataProviderMessageInfo > > KafkaDataProvider::KafkaConsumerDataProvider::getEventTypesImpl | ( | ) |
Returns a hash of all supported event types.
| void KafkaDataProvider::KafkaConsumerDataProvider::stopEvents | ( | ) |
Called to stop generating events.
Stops polling for new events