There are couple of Kafka input operators like KafkaSinglePortBytesInputOperator and KafkaSinglePortInputOperator that extends AbstractKafkaInputOperator. They are part of malhar library.
They can right away consume messages from kafka topics. Thanks!! On Monday, October 24, 2016, Raja.Aravapalli <raja.aravapa...@target.com> wrote: > > > Hi, > > > > Do we have any kaka operator readily available to consume messages from > secure kafka topics in kafka 0.9 clusters? > > > > Thanks a lot. > > > > > > Regards, > > Raja. >
