【发布时间】:2021-10-29 18:28:35
【问题描述】:
我们可以为 kafka ProducerRecord 构造函数指定一个时间戳。
public ProducerRecord(String topic, Integer partition, Long timestamp, K key, V value, Iterable<Header> headers)
这个时间采样的预期用途是什么?它是否与消息一起传输到 kafka 代理?
【问题讨论】:
标签: apache-kafka kafka-producer-api