diff --git a/src/reference/asciidoc/kafka.adoc b/src/reference/asciidoc/kafka.adoc index 4489b39c..4f94922f 100644 --- a/src/reference/asciidoc/kafka.adoc +++ b/src/reference/asciidoc/kafka.adoc @@ -2216,9 +2216,9 @@ public ConsumerFactory kafkaConsumerFactory(KafkaProperties properties @Bean public ProducererFactory kafkaProducerFactory(KafkaProperties properties, - JsonSserializer customSerializer) { + JsonSerializer customSerializer) { - return new DefaultKafkaConsumerFactory<>(properties.buildProducerProperties(), + return new DefaultKafkaProducerFactory<>(properties.buildProducerProperties(), customSerializer, customSerializer); } ----