apache-kafka-streams - json String to Object 自动转换在 Spring Cloud Stream 中是如何工作的？

Question

我正在看这个例子 - https://github.com/spring-cloud/spring-cloud-stream-samples/blob/master/kafka-streams-samples/kafka-streams-product-tracker/src/main/java/kafka/streams/product/tracker/KafkaStreamsProductTrackerApplication.java

试图做类似的事情，但对我来说它不起作用。如何将产品 json 字符串作为产品对象接收？

Answer 1

默认情况下，入站 KStream 上的反序列化由 Spring Cloud Stream 完成。使用的默认内容类型是 application/json (相当于提供属性: spring.cloud.stream.bindings.input.contentType: application/json )。这就是产品json字符串被正确转换的原因。

您可以禁用框架级别转换并让 Kafka 执行此操作，在这种情况下，您需要通过属性提供 Serdes。为了启用 native 反序列化，您可以设置属性 - spring.cloud.stream.bindings.input.consumer.useNativeDecoding: true .然后你需要提供合适的Serdes。关于所有这些的更多信息在这里:https://docs.spring.io/spring-cloud-stream/docs/Elmhurst.BUILD-SNAPSHOT/reference/htmlsingle/#_message_conversion