Как потребитель Kafka может десериализовать объект dto, отправленный производителем? ⇐ JAVA

[Anonymous]

Я использую Spring для отправки сообщения потребителю Kafka.

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

this.kafkaTemplate.send(applicationProperties.getKafka().getTopics().getNoticeGenerationEventsTopic(),
japserName, noticeEventDTO);

Но kafka не может десериализовать notitEventDTO dto, поскольку не знает об этом DTO. Это из микросервиса отправителя.
Как я могу сообщить Kafka об этом классе, чтобы он мог десериализовать класс?
Я получаю следующую ошибку:

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

Caused by: org.springframework.messaging.converter.MessageConversionException: failed to resolve class name. Class not found [com.xyz.abc.registration.service.dto.NoticeEventDTO]
at org.springframework.kafka.support.mapping.DefaultJackson2JavaTypeMapper.getClassIdType(DefaultJackson2JavaTypeMapper.java:137)
at org.springframework.kafka.support.mapping.DefaultJackson2JavaTypeMapper.toJavaType(DefaultJackson2JavaTypeMapper.java:98)
at org.springframework.kafka.support.converter.JsonMessageConverter.determineJavaType(JsonMessageConverter.java:135)
at org.springframework.kafka.support.converter.JsonMessageConverter.extractAndConvertValue(JsonMessageConverter.java:107)
at org.springframework.kafka.support.converter.MessagingMessageConverter.toMessage(MessagingMessageConverter.java:193)
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.toMessagingMessage(MessagingMessageListenerAdapter.java:346)
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:83)
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:53)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2857)
... 12 common frames omitted
Caused by: java.lang.ClassNotFoundException: com.abc.xyz.registration.service.dto.NoticeEventDTO
at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(BuiltinClassLoader.java:641)
at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(ClassLoaders.java:188)
at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:520)
at java.base/java.lang.Class.forName0(Native Method)
at java.base/java.lang.Class.forName(Class.java:467)
at org.springframework.boot.devtools.restart.classloader.RestartClassLoader.loadClass(RestartClassLoader.java:121)
at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:520)
at java.base/java.lang.Class.forName0(Native Method)
at java.base/java.lang.Class.forName(Class.java:467)
at org.springframework.util.ClassUtils.forName(ClassUtils.java:304)
at org.springframework.kafka.support.mapping.DefaultJackson2JavaTypeMapper.getClassIdType(DefaultJackson2JavaTypeMapper.java:133)
... 20 common frames omitted

Класс не найден — это полное имя класса dto производителя.

Подробнее здесь: https://stackoverflow.com/questions/790 ... y-producer