Kafka--对《消费者》中对象的反序列化

Question

我们正在考虑在我们的for消息传递中使用Kafka，我们的应用程序是使用Spring开发的。所以，我们已经计划用Spring-Kafka。

生产者将消息作为HashMap对象放入队列。我们有JSON序列化器，并且假设映射将被序列化并放入队列。这是生产者配置。

spring:
  kafka:
    bootstrap-servers: localhost:9092
    producer:
        key-serializer: org.springframework.kafka.support.serializer.JsonSerializer
        value-serializer: org.springframework.kafka.support.serializer.JsonSerializer

spring:
   kafka:
       consumer:
            group-id: xyz
            key-deserializer: org.springframework.kafka.support.serializer.JsonDeserializer
            value-deserializer: org.springframework.kafka.support.serializer.JsonDeserializer

  public void listener(SomeClass abx)

我们看到的文章很少，建议是这样做：

 @Bean
  public ConsumerFactory<String, Car> consumerFactory() {
    return new DefaultKafkaConsumerFactory<>(consumerConfigs(), new StringDeserializer(),
        new JsonDeserializer<>(Car.class));
  }

我们不想为创建反序列化程序编写一些代码。有没有我们缺少的样板？任何帮助都将不胜感激！！

Answer 1

请参阅引导文档。特别是：

您还可以按照如下方式配置Spring Kafka JsonDeserializer：

spring.kafka.consumer.value-deserializer=org.springframework.kafka.support.serializer.JSONDeserializer

spring.kafka.consumer.properties.spring.json.value.default.type=com.example.invoide

spring.kafka.consumer.properties.spring.json.trusted.packages=com。示例，org.acme