草庐IT

TimestampExtractor

全部标签

java - Kafka - TimestampExtractor 的问题

我使用org.apache.kafka:kafka-streams:0.10.0.1我正在尝试使用一个基于时间序列的流,它似乎不会触发KStream.Process()来触发(“标点符号”)。(引用here)在KafkaStreams配置中,我传递了这个参数(以及其他参数):config.put(StreamsConfig.TIMESTAMP_EXTRACTOR_CLASS_CONFIG,EventTimeExtractor.class.getName());这里,EventTimeExtractor是一个自定义时间戳提取器(实现了org.apache.kafka.streams.pr