1

我正在为 KafkaSource 使用projectionFn，以便将 JSON 字符串解析为我的 kafka 消息值。

Vertex kafkaSource = dag.newVertex("kafkaSource", streamKafkaP(properties, decodeKafkaMessage, topic));

但是，kafka 文档将消息/记录定义为：

- a key,
- a value,
- and a timestamp. (built-in timestamp)

通过projectionFn，看起来我只能从每条消息中访问键和值。我怎么能通过Kafka timestamp.extractor访问时间戳值？

4

0 回答 0