Flink, как правило, не делает никакой связи между разделением, выполняемым во время потоковой обработки через keyBy, и разделением, которое существует на уровне потокового хранения в Kafka. Если вы используете keyBy в потоке, поступающем от потребителя Kafka, все события для каждого пользователя будут обрабатываться вместе, независимо от того, с какого раздела kafka они поступают.
Я не понимаю, что вы пытаетесь сделатьда, но вы можете прочитать о том, как Flink обрабатывает поиск тем и разделов Kafka в документации .