Inkompatible Typen beim Versuch der Serialisierung mit dem Produzenten -Customizer ⇐ Java

[Anonymous]

Ich benutze Spring für Kafka und möchte den StandardkafkaproducerFactoryCustomizer verwenden, um meine Produzentenfabrik anzupassen, da ich mehrere Wertes Serializer benötige. Daher beginne ich mit

Code: Select all

  @Bean
public DefaultKafkaProducerFactoryCustomizer defaultKafkaProducerFactoryCustomizer() {
return (producerFactory) -> {
producerFactory.setKeySerializer(new StringSerializer());
};
}
< /code>
Aber der Compiler ist nicht glücklich < /p>
incompatible types: org.apache.kafka.common.serialization.StringSerializer cannot be
converted to org.apache.kafka.common.serialization.Serializer

Das gleiche Problem mit (Ich verwende den BytearraySerializer , um eine Nachricht zu senden, die nicht zu DLQ zu Deserialize wurde)

Code: Select all

  producerFactory.setValueSerializer(
new DelegatingByTypeSerializer(
Map.of(
byte[].class,
new ByteArraySerializer(),
Foo.class,
new JsonSerializer())));
< /code>
Ich habe: < /p>
incompatible types: org.springframework.kafka.support.serializer.DelegatingByTypeSerializer
cannot be converted to org.apache.kafka.common.serialization.Serializer
< /code>
Aber es funktioniert gut mit nur < /p>
producerFactory.setValueSerializer(new JsonSerializer());

Die DefaultKafkaproducerFactoryCustomizer -Klasse ist so definiert

Code: Select all

@FunctionalInterface
public interface DefaultKafkaProducerFactoryCustomizer {

/**
* Customize the {@link DefaultKafkaProducerFactory}.
* @param producerFactory the producer factory to customize
*/
void customize(DefaultKafkaProducerFactory producerFactory);

}

Wie kann ich dieses Problem lösen?>