gpt4 book ai didi

java - 如何从 Kafka RecordHeaders 获取 key 和 value

转载 作者:行者123 更新时间:2023-12-05 03:43:29 27 4
gpt4 key购买 nike

我有一个 ProducerRecord 对象。

ProducerRecord<String, byte[]> hdr = addHeader.addMDGHeader(record);

我正在尝试编写一个测试来检查是否存在特定的 header 键。

如果我打印 hdr.headers().toString() 我得到以下 RecordHeaders(headers = [RecordHeader(key = mdpHeader, value = [123, 34, 83, 101 , 113, 117, 101, 110, 99, 101, 78, 111, 34, 58, 48, 44, 34, 84, 101, 109, 112, 108, 97, 116, 101, 115, 34, 58, 91 , 93, 125])], isReadOnly = false).

如何提取mdpHeader

最佳答案

Header.value()方法返回字节数组byte[],然后可以将其转换成字符串,更多例子可以看here

String value = new String(header.value(), StandardCharsets.UTF_8);

关于java - 如何从 Kafka RecordHeaders 获取 key 和 value,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/66772007/

27 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com