Qore jni Module 2.6.0
Loading...
Searching...
No Matches
KafkaDataProvider::KafkaConsumerDataProvider Class Reference

Event-based data provider for Kafka events. More...

#include <KafkaConsumerDataProvider.qc.dox.h>

Inheritance diagram for KafkaDataProvider::KafkaConsumerDataProvider:
KafkaDataProvider::KafkaDataProviderBase

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.
 

Detailed Description

Event-based data provider for Kafka events.

Member Function Documentation

◆ getEventTypesImpl()

hash< string, hash< DataProviderMessageInfo > > KafkaDataProvider::KafkaConsumerDataProvider::getEventTypesImpl ( )

Returns a hash of all supported event types.

Returns
a hash of all supported event types
Note
only called if the provider supports the observer pattern / event API

◆ stopEvents()

void KafkaDataProvider::KafkaConsumerDataProvider::stopEvents ( )

Called to stop generating events.

Stops polling for new events


The documentation for this class was generated from the following file: