Flink how to discover all kafka partitions per key

  • Thread starter Mohammad Hossein Gerami
  • Start date
M

Mohammad Hossein Gerami

Guest
I using "keyby" in my data stream. i want flink discover all kafka partitions per key. I have 30 partition & 12 tasks. I "keyby" my data by user id. I think flink per task just discover specific kafka partition & i can not detect all data per user in one task.

Continue reading...
 
Top