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

[Anonymous]

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

файл производительности , как следующий

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

    @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);

Файл свойств потребителей

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

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

Код контроллера потребителя

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

@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
}

error

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

 `Caused by: org.apache.kafka.common.KafkaException: Failed to construct kafka consumer`

метод Trubleshooted

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

 By adding

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

and

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

Измененный код и ошибка
Модифицировано с добавлением следующего в приложении производителя.properties

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

spring.kafka.producer.properties.spring.json.type.mapping=orderEvent:com.order.model.OrderEvent

и добавил следующее с Consumer Application.properties

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

spring.kafka.consumer.properties.spring.json.type.mapping=orderEvent:com.payment.model.OrderEvent

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

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