diff --git a/src/reference/asciidoc/kafka.adoc b/src/reference/asciidoc/kafka.adoc index b4da8f5f..6dd67e0b 100644 --- a/src/reference/asciidoc/kafka.adoc +++ b/src/reference/asciidoc/kafka.adoc @@ -2259,7 +2259,7 @@ public KafkaListenerContainerFactory factory = new ConcurrentKafkaListenerContainerFactory<>(); ... - factory.getContainerProperties().setErrorHandler(myErrorHandler); + factory.setErrorHandler(myErrorHandler); ... return factory; } @@ -2332,8 +2332,8 @@ public ConcurrentKafkaListenerContainerFactory kafkaListenerCont ConcurrentKafkaListenerContainerFactory factory = new ConcurrentKafkaListenerContainerFactory(); factory.setConsumerFactory(consumerFactory()); factory.getContainerProperties().setAckOnError(false); - factory.getContainerProperties().setErrorHandler(new SeekToCurrentErrorHandler()); factory.getContainerProperties().setAckMode(AckMode.RECORD); + factory.setErrorHandler(new SeekToCurrentErrorHandler()); return factory; } ----