Spring/spring-kafka
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

GH-862: Fix docs for ErrorHandler

Browse Source 
Fixeds https://github.com/spring-projects/spring-kafka/issues/862
This commit is contained in:
Gary Russell
2018-11-06 09:55:39 -05:00
parent 56f5bfb8c5
commit 7bf2c647ff
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/reference/asciidoc/kafka.adoc
View File

@@ -2259,7 +2259,7 @@ public KafkaListenerContainerFactory<ConcurrentMessageListenerContainer<Integer,
ConcurrentKafkaListenerContainerFactory<Integer, String> factory =
new ConcurrentKafkaListenerContainerFactory<>();
...
factory.getContainerProperties().setErrorHandler(myErrorHandler);
factory.setErrorHandler(myErrorHandler);
...
return factory;
}
@@ -2332,8 +2332,8 @@ public ConcurrentKafkaListenerContainerFactory<String, String> kafkaListenerCont
ConcurrentKafkaListenerContainerFactory<String, String> 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;
}
----