Непонятно, какой порядок вам нужен (по какому-то UUID, серверу, производящему данные, по какому-либо другому типу событий и т. Д.), Но упорядочение сообщений Kafka гарантируется только в разделах любой темы, и любые потребители Kafka, включая Flink, гарантированнопрочитайте назначенный ему раздел по порядку.
Разделитель Kafka по умолчанию, используемый производителем, будет использовать алгоритм хеширования Murmur2 , если вы указали ключ.Если у вас есть нулевой ключ, он будет равномерно распределять все разделы.
Производитель Flink переписывает это поведение в прошлый раз, когда я проверял.См. FLINK-9610 .Если вы используете Flink только в качестве потребителя, вам не нужно беспокоиться об этом.
По умолчанию сообщения в Кафке помечены