kafkakafka 消息头的强大功能

Posted 九师兄

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了kafkakafka 消息头的强大功能相关的知识,希望对你有一定的参考价值。

文章目录


1.概述

Apache Kafka 0.11引入了记录头的概念。记录标题使您能够添加一些有关Kafka记录的元数据,而无需在记录本身的键/值对中添加任何额外的信息。考虑是否要在消息中嵌入一些信息,例如数据所源自的系统的标识符。也许您希望这样做是为了沿袭和审核目的,以便于向下游路由数据。

Apache Kafka 0.11 引入了消息头的概念。消息头让你能够添加一些关于 Kafka 记录的元数据,而不需要向记录本身的键/值对添加任何额外的信息。考虑是否要在消息中嵌入一些信息,例如数据所源自系统的标识符,这样我们可以做一些审计相关的统计。

Adding headers to Kafka records#
下面是使用 Java 代码给 ProducerRecord 添加消息头:

ProducerRecord<String, String

以上是关于kafkakafka 消息头的强大功能的主要内容,如果未能解决你的问题,请参考以下文章

KafkaKafka是什么

kafkakafka 中 消息 record 格式

KafkaKafka版本的 watermark 迟来的消息 直接报错

kafkaKafka 幂等 Producer

Kafkakafka方式消息不丢失的一些参数设置

kafkakafka 消息 重放 从 一个 topic 导入 另外一个 topic