java - 如何解析kafka流中的kafka标头？
问题描述
我正在开发一个 PoC 以使用 Java 中的 kafka 流并基于 kafka 消息头值来使用来自 kafka 主题的提要，我需要根据头值进行不同的处理。这些标头将是自定义标头，由生产者在 kafka 主题上提供。
我们在 PoC 中使用 kafka 1.1.1，在我的 PoC 中也使用 kafka-streams 1.1.1 版本。我试图在互联网上搜索很多，但无法具体。
解决方案
推荐阅读
- c - 获得不太理想的解决方案 TSP
- php - 如何在 laravel 中使用 createmany 插入 2 个数组
- c# - 有没有更好的方法来定位辅助窗口相对于主窗口的启动位置？
- javascript - 测试失败 - ProductService 不是构造函数
- c++11 - 无论我使用哪种初始化（统一、赋值等），std::string 的初始化似乎都会生成相同的代码
- machine-learning - 如何将 Pytorch 模型参数转换为长数据类型？
- c++ - 如何将两个值相乘并以原子方式存储结果？
- reactjs - react服务和组件之间如何通信？
- react-native - 如何在本机反应中从领域数据库中读取数据？
- java - 数组的 Jackson-CSV 模式