apache-kafka - kafka 标头和键值对

Question

我遇到了 kafka 标头的此链接。如以下链接中所述

kafka 标头https://cwiki.apache.org/confluence/display/KAFKA/KIP-82+-+Add+Record+Headers

我可以在 producer-api 中使用键/值对来发送标头和有效负载信息吗？我看到了关于日志压缩的一点，我可以关闭日志压缩，以便在我的情况下每个键都是唯一的，日志不会跟踪每条记录吗？

我确实创建了一个具有键值对的生产者，其中键具有标头信息，值是有效负载。每把钥匙都是独一无二的。

消费者也收到了正确的键值对。

我想知道在大容量日志压缩中使用这种方法获取标头信息是否会有任何问题。是否可以选择关闭日志合并并让保留清理旧数据？

标签： apache-kafkakafka-consumer-apikafka-producer-api

Answer 1

标头不控制日志压缩。

是的，您可以producer.send() 使用ProducerRecordHeaders

打开或关闭日志压缩，保留窗口内唯一键的所有记录都会保留，所以不确定我是否理解这个问题