The new operator for Kafka 0.9 can read multiple topics.
On Wed, Jan 27, 2016 at 5:02 PM, Munagala Ramanath <r...@datatorrent.com> wrote: > 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. >> > >
