【发布时间】：2022-01-09 09:03:57
【问题描述】：
我有 2 个 Spring Boot 应用程序。我正在尝试以消费者可以接收生产者发送的消息的方式映射到 application.properties 文件中。我想补充一点，我正在使用 CustomMessage：
public class CustomMessage {
private LocalDateTime timestamp;
private Integer sensor_id;
private Double measurement_value;
// getters and setters
}
我的生产者的 application.properties 文件：
# other properties ( I use CloudKarafka )
spring.kafka.producer.key-serializer= org.apache.kafka.common.serialization.StringSerializer
spring.kafka.producer.value-serializer= org.springframework.kafka.support.serializer.JsonSerializer
spring.kafka.producer.properties.spring.json.type.mapping=customMessage:assignment2.kafka.CustomMessage,customMessage:ro.tuc.ds2020.kafkaconsumer.CustomMessage
对于消费者而言：
spring.kafka.consumer.key-deserializer= org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.value-deserializer= org.springframework.kafka.support.serializer.JsonDeserializer
spring.kafka.consumer.properties.spring.json.type.mapping=customMessage:ro.tuc.ds2020.kafkaconsumer.CustomMessage, customMessage:assignment.kafka.CustomMessage
我不确定 type.mapping 应该如何完成。以这种方式呈现，我得到以下错误：
Failed to construct kafka consumer
Failed to load: assignment.kafka.CustomMessage for customMessage
也无法构建生产者。
【问题讨论】：
标签： java apache-kafka kafka-consumer-api