Вызвано: java.lang.illegalargumentException: не удалось загрузить: orderevent для ошибки orderevent при потреблении объе ⇐ JAVA

[Anonymous]

вызван: java.lang.illegalargumentException: не удалось загрузить: orderevent для ошибки orderevent, которую я получаю, используя тему типа объекта в моем потребителе Apache Kafka. Я пытаюсь передать объект OrdereVent от продюсера, чтобы потреблять. Но в то время как я запускаю потребителя, я получаю вышеупомянутую ошибку < /p>
Я требую следующих ссылок, чтобы привести к обращению, когда получил эту ошибку. И во время чтения я узнал об этом, это происходит из -за того, что отображение необходимо явно определить в моем приложении. Прозрачные файлы
Ссылки
https://docs.spring.io/spring-kafka/ref ... pesобразно /> Application.properties Производитель сторона < /p>

Код: Выделить всё

spring.kafka.bootstrap-servers=localhost:9092
spring.kafka.consumer.group-id=orders-group
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=OrderEvent:com.order.model.OrderEvent,OrderEvent:OrderEvent
< /code>
файл ProducterService, как следующий < /p>
    @Autowired
private KafkaTemplate kafkaTemplate;

OrderEvent orderEvent =  new OrderEvent();
orderEvent.oid = orderObj.getOid();
orderEvent.pid=orderObj.getPid();
orderEvent.quantity=orderObj.getQuantity();
orderEvent.mode=orderObj.getMode();
kafkaTemplate.send("order-create-event", orderEvent);
< /code>
Файл свойств потребителей < /p>
spring.kafka.bootstrap-servers=localhost:9092
spring.kafka.consumer.group-id=orders-group
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.trusted.packages=*
spring.kafka.consumer.properties.spring.json.type.mapping=OrderEvent:com.payment.model.OrderEvent,OrderEvent:OrderEvent
< /code>
Код контроллера потребителя < /p>
@KafkaListener(topics = "order-create-event", groupId = "orders-group")
public void processOrder(OrderEvent orderEventObj) throws JsonMappingException, JsonProcessingException {

Carts cartObj = new Carts();
cartObj.setPid(orderEventObj.pid);
cartObj.setOid(orderEventObj.oid);
cartObj.setStatus(orderEventObj.status);
cartObj.setMode(orderEventObj.mode);
cartRepo.save(cartObj);
// remaining codes
}
< /code>
ошибка < /p>
 `Caused by: org.apache.kafka.common.KafkaException: Failed to construct kafka consumer`
< /code>
Trubleshooted Метод < /p>
 By adding

`spring.kafka.producer.properties.spring.json.type.mapping`

and

`spring.kafka.consumer.properties.spring.json.trusted.packages=*`

Я недавно начал исследовать Springboot с Apache Kafka, может кто -нибудь предложить, где я ошибся в реализации, или предложить любую документацию, чтобы обозначить эту проблему?

Подробнее здесь: https://stackoverflow.com/questions/797 ... ent-for-or