Hi, Is it possible that the Kafka partition assignment logic has changed between Flink 1.3 and 1.4? I am trying to migrate some jobs using Kafka 0.8 sources and about half my jobs lost offset state for some partitions (but not all partitions). Jobs with parallelism 1 dont seem to be affected...
Any ideas? Gyula
