Kafka消息值从Integer到String的转换
Kafka message Value conversion from Integer to String
我在一个 kafka 主题中有一条 kafka 消息。此消息的键之一 key=ID
和该键的值是 value=12345678910111213141
。
此值的类型是 integer
。我想将类型转换为 string
。
目前我正在以一些 hacky 的方式进行此操作:
- 消费消息
- 转换类型
- 向其他主题生成消息
有更简单的方法吗?
PS:无权访问第一个发送消息的生产者 integer
。
如果我没有正确理解你的问题,这是不可能的。就 Kafka 而言,所有数据都以字节形式存储,Kafka 不知道使用哪个 Serializer 来生成字节码。
因此,您只能按照 Producer 序列化的方式反序列化该值。据我了解,这是使用 Integer Serializer 完成的。但是由于您无权访问 Producer,因此您只能将其作为 Integer 读取并随后将其转换为 String。
我在一个 kafka 主题中有一条 kafka 消息。此消息的键之一 key=ID
和该键的值是 value=12345678910111213141
。
此值的类型是 integer
。我想将类型转换为 string
。
目前我正在以一些 hacky 的方式进行此操作:
- 消费消息
- 转换类型
- 向其他主题生成消息
有更简单的方法吗?
PS:无权访问第一个发送消息的生产者 integer
。
如果我没有正确理解你的问题,这是不可能的。就 Kafka 而言,所有数据都以字节形式存储,Kafka 不知道使用哪个 Serializer 来生成字节码。
因此,您只能按照 Producer 序列化的方式反序列化该值。据我了解,这是使用 Integer Serializer 完成的。但是由于您无权访问 Producer,因此您只能将其作为 Integer 读取并随后将其转换为 String。