【问题标题】:Where is Kafka header for it's messages stored?Kafka 标头的消息存储在哪里?
【发布时间】:2021-09-02 22:26:23
【问题描述】:

我正在使用 Kafka 标头传递相关 ID 以进行日志记录,然后 Kafka 拦截器使用该 ID 将其放入 MDC。我的问题是标题信息准确存储在哪里,我的 postgres DB 没有任何用于存储消息标题信息的列,那么 kafka 将这些信息存储在哪里?它使用哪个数据存储? 以下是我的 kafka_message 表的列名。没有一列存储标题信息。

【问题讨论】:

    标签: database apache-kafka header spring-kafka


    【解决方案1】:

    标头是记录的一部分,作为字节,而不是特定的“数据存储”

    https://kafka.apache.org/documentation/#record

    您需要检查用于将数据写入 Postgres 的此过程的代码,以查看是否甚至“支持”标头,因为它们是 Kafka 协议的一个相对较新的功能

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 1970-01-01
      • 2013-02-13
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2016-02-22
      • 2012-11-08
      • 2021-09-27
      相关资源
      最近更新 更多