Re: Flink does not read from some Kafka Partitions

Thank you both for your responses. Looks like I may have inadvertently used 1.3.1 libraries instead of 1.4. Ruby On Wed, May 16, 2018 at 3:12 AM Tzu-Li (Gordon) Tai wrote: > Hi, > > Timo is correct - partition discovery is supported by the consumer only > starting from Flink 1.4. > > The expect

Flink does not read from some Kafka Partitions

Hello, My team ran into some behavior we did not expect when we tried to get an existing Flink app to read from a re-sized Kafka. Here are the highlights: - We are using the FlinkKafkaConsumer010. - We re-partitioned (added partitions to) an existing topic that our Flink app reads so that it th