所以我在经营Kafka,有两个主题,他们都会提供文件-
主题1-我从中读取字符串值并对其进行处理。主题2-我需要二进制值进行处理。
所以我猜我需要两个消费者?这背后的原因是,在第一个主题的数据属性中,我需要一个stringserializer/反序列化程序,而对于第二个主题,我需要一个binaryarrayserializer反序列化程序。
那么,有两个消费者实现是可行的吗?
我知道我可以得到字符串值并将其转换为二进制,反之亦然,但不知何故,拥有两个消费者似乎是一种干净的方法。
提前谢谢。
所以我在经营Kafka,有两个主题,他们都会提供文件-
主题1-我从中读取字符串值并对其进行处理。主题2-我需要二进制值进行处理。
所以我猜我需要两个消费者?这背后的原因是,在第一个主题的数据属性中,我需要一个stringserializer/反序列化程序,而对于第二个主题,我需要一个binaryarrayserializer反序列化程序。
那么,有两个消费者实现是可行的吗?
我知道我可以得到字符串值并将其转换为二进制,反之亦然,但不知何故,拥有两个消费者似乎是一种干净的方法。
提前谢谢。
暂无答案!
目前还没有任何答案,快来回答吧!