|
Type |
Name |
Description |
|
Processor |
ConsumeKafka |
Supports consumption of Kafka messages through the Apache Kafka Consumer API. Complementary processor for sending messages is PublishKafka.
|
|
Processor |
PublishKafka |
Sends contents of a FlowFile as either a message or as individual records to Apache Kafka using the Kafka Producer API. Complementary processor for fetching messages is ConsumeKafka.
|