You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by John O <so...@samsung.com> on 2018/08/20 22:15:25 UTC

Access to kafka partition per record

I am consuming data from a kafka topic that has multiple partitions. I would like to keyby(record.partition). What would be the best way to get access to the partition information?


Jo