java - java中的多个Kafka消费者
问题描述
因此，我正在运行带有两个主题的 kafka，它们都将提供文件-
主题 1 - 我正在从中读取字符串值并对其进行处理。主题 2 - 我需要二进制值进行处理。
所以我猜我需要两个消费者？这背后的原因是，在来自第一个主题的数据的属性中，我需要一个 StringSerializer/Deserializer，而对于第二个主题，我需要一个 BinaryArraySerializer Desererializer。
那么有两个消费者实现是否可行？
我知道我可以获取字符串值并将其转换为二进制值，反之亦然，但不知何故，拥有两个消费者似乎是一种干净的方式。
提前致谢。
解决方案
推荐阅读
- arrays - 这是什么意思：项目：数组
- java - 修改列表内对象数据成员的文本
- c++ - 如何放大 Mandelbrot Set 中的光标点？
- python - 通过Python使用find_element时Selenium找不到元素
- machine-learning - 使用交叉验证选择最佳阈值：Keras 中的二元分类
- c++ - 将值分配给通过引用传递的 int 会停止程序执行
- database - 如何在 Dolphindb 中取消作业
- html - 如何在保持纵横比的同时使图像扩大/缩小到可用空间
- javascript - 使用 Socket IO 和 aiohttp 进行节点 JS 和 Python 之间的数据传输
- r - 试图绘制朴素贝叶斯输出但出现错误 - “x”是一个列表，但没有组件“x”和“y”