Re: Clarifications on FLINK-KAFKA consumer

2017-09-22 Thread Tzu-Li (Gordon) Tai
Hi Rahul! 1. Will FLink-Kafka consumer 0.8x run on multiple task slots or a single task slot? Basically I mean if its going to be a parallel operation or a non parallel operation? Yes, the FlinkKafkaConsumer is a parallel consumer. 2. If its a parallel operation, then do multiple task slots

Clarifications on FLINK-KAFKA consumer

2017-09-22 Thread Rahul Raj
Hi, I have just started working with FLINK and I am working on a project which involves reading KAFKA data and processing it. Following questions came to my mind: 1. Will FLink-Kafka consumer 0.8x run on multiple task slots or a single task slot? Basically I mean if its going to be a parallel