Since a single AbstractKafkaInputOperator has a single KafkaConsumer and the latter has only a single topic, it appears that the only option is to have one input operator per topic.
There also seems to be some machinery to get a reasonable mapping of input operator partitions to topic partitions, so this also points to needing an input operator per topic. Ram On Wed, Jan 27, 2016 at 4:24 PM, Ashwin Chandra Putta < ashwinchand...@gmail.com> wrote: > Hi, > > Does the kafka input operator support reading from multiple kafka topics? > What is the suggested approach to deal with reading from multiple topics? > > -- > > Regards, > Ashwin. >
