VG
Size: a a a
VG
S🕶
props.put(JsonDeserializer.TRUSTED_PACKAGES, "*");
- добавил эту строку ошибка не поменялась,org.apache.kafka.common.errors.SerializationException: Error deserializing key/value for partition create-ticket-0 at offset 63. If needed, please seek past the record to continue consumption.
Caused by: java.lang.IllegalArgumentException: The class 'com.example.application.domain.command.CreateTicketCommand' is not in the trusted packages: [java.util, java.lang]. If you believe this class is safe to deserialize, please provide its name. If the serialization is only done by a trusted source, you can also enable trust all (*).
VG
props.put(JsonDeserializer.TRUSTED_PACKAGES, "*");
- добавил эту строку ошибка не поменялась,org.apache.kafka.common.errors.SerializationException: Error deserializing key/value for partition create-ticket-0 at offset 63. If needed, please seek past the record to continue consumption.
Caused by: java.lang.IllegalArgumentException: The class 'com.example.application.domain.command.CreateTicketCommand' is not in the trusted packages: [java.util, java.lang]. If you believe this class is safe to deserialize, please provide its name. If the serialization is only done by a trusted source, you can also enable trust all (*).
S🕶
@Bean
public ConcurrentKafkaListenerContainerFactory<String, CreateTicketCommand> createTicketListenerContainerFactory() {
ConcurrentKafkaListenerContainerFactory<String, CreateTicketCommand> factory = new ConcurrentKafkaListenerContainerFactory<>();
factory.setConsumerFactory(genericConsumerFactory(CreateTicketCommand));
return factory;
}