Operators: com.teracloud.streams.kafka 5.0.0 Operators KafkaConsumer The KafkaConsumer operator is used to consume messages from Kafka topics. KafkaProducer The KafkaProducer operator is used to produce messages on Kafka topics.