Package | Description |
---|---|
org.wso2.carbon.inbound.endpoint.protocol.kafka |
Modifier and Type | Class and Description |
---|---|
class |
KAFKAInjectHandler
KafkaInjectHandler uses to mediate the received Kafka message
|
Modifier and Type | Field and Description |
---|---|
protected InjectHandler |
AbstractKafkaMessageListener.injectHandler |
Modifier and Type | Method and Description |
---|---|
void |
KAFKAPollingConsumer.registerHandler(InjectHandler processingHandler)
Register a handler to implement injection of the retrieved message
|
Constructor and Description |
---|
KAFKAMessageListener(int threadCount,
List<String> topics,
Properties kafkaProperties,
InjectHandler injectHandler) |
SimpleKafkaMessageListener(Properties kafkaProperties,
InjectHandler injectHandler) |
Copyright © 2021 WSO2. All rights reserved.