多个 KafkaListener / 一个主题

Question

我正在使用 spring-kafka 2.2.12，我才刚刚开始。

我想通过 kafka 管理业务实体的创建/更新。如果可能，在同一主题中，保证顺序（通过提供业务密钥）。由于这不是相同的 java 类型（创建和请求），我想我需要有 2 个 KafkaListener（带有他们自己的 ContainerFactory / JsonDeserializer）。也许我错了？

所以我的问题是：是否有可能有不同的 KafkaListener（因为反序列化）消耗相同的主题（以保持消息的顺序）？

也许我没有以正确的方式接近主题......我没有设法在一个 KafkaListener 中使用不同的对象类型。

谢谢。

Answer 1

如果生产者也是Spring，并且使用JsonSerializer；它将在标题中添加类型信息（默认情况下），JsonDeserializer 使用它来创建目标对象。

如果类型不同（源和目标），但从 JSON 角度来看是类型兼容的，您可以将类型映射信息添加到反序列化器。

如果源不是Spring也可以使用类型映射（但可以修改设置类型信息头）。

见the documentation。

您还可以使用Delegating serializer/deserializer 根据某些标头调用不同的实现。