Как использовать Flink воспроизведения истории данных (не в порядке) в Кафке - PullRequest
Новая
       10

Как использовать Flink воспроизведения истории данных (не в порядке) в Кафке

0 голосов
/ 08 апреля 2020

как использовать данные истории воспроизведения Flink (не по порядку) в kafka

Мне интересно, как использовать данные истории воспроизведения Flink в kafka, а данные истории не в порядке? 

private static String START_TIME = "2020-02-08 00:50:00";
FlinkKafkaConsumer011<String> kafkaConsumer = KafkaProperties.getKafkaConsumer(KAFKA_TOPIC_CONSUMER);
kafkaConsumer.setStartFromTimestamp(Timestamp.valueOf(START_TIME).getTime());
DataStream<String> kafkaStreamOperator = env.addSource(kafkaConsumer).name(KAFKA_TOPIC_CONSUMER).uid(KAFKA_TOPIC_CONSUMER);

Фактически мы зависим от времени события данных, но когда мы воспроизводим историю, это не в порядке!

надеюсь, что кто-нибудь может дать мне некоторое представление.

...