This Processors polls Apache Kafka for data using KafkaConsumer API available with Kafka 0.10+. When a message is received from Kafka, this Processor emits a FlowFile where the content of the FlowFile is the value of the Kafka message.