Fix docs for batch error handler

This commit is contained in:
Gary Russell
2019-05-03 09:49:36 -04:00
parent 40b21c1cd2
commit a587b134de

View File

@@ -2679,7 +2679,7 @@ public KafkaListenerContainerFactory<ConcurrentMessageListenerContainer<Integer,
ConcurrentKafkaListenerContainerFactory<Integer, String> factory =
new ConcurrentKafkaListenerContainerFactory<>();
...
factory.getContainerProperties().setBatchErrorHandler(myBatchErrorHandler);
factory.setBatchErrorHandler(myBatchErrorHandler);
...
return factory;
}