Start building against Spring Kafka 2.8.3 snapshots

See gh-29759
This commit is contained in:
Stephane Nicoll 2022-02-14 08:22:13 +01:00
parent d925c8d317
commit 15e14e23c9
4 changed files with 5 additions and 2 deletions

View File

@ -169,6 +169,7 @@ public class ConcurrentKafkaListenerContainerFactoryConfigurer {
configureContainer(listenerFactory.getContainerProperties()); configureContainer(listenerFactory.getContainerProperties());
} }
@SuppressWarnings("deprecation")
private void configureListenerFactory(ConcurrentKafkaListenerContainerFactory<Object, Object> factory) { private void configureListenerFactory(ConcurrentKafkaListenerContainerFactory<Object, Object> factory) {
PropertyMapper map = PropertyMapper.get().alwaysApplyingWhenNonNull(); PropertyMapper map = PropertyMapper.get().alwaysApplyingWhenNonNull();
Listener properties = this.properties.getListener(); Listener properties = this.properties.getListener();

View File

@ -512,6 +512,7 @@ class KafkaAutoConfigurationTests {
} }
@Test @Test
@Deprecated
void testConcurrentKafkaListenerContainerFactoryWithCustomErrorHandler() { void testConcurrentKafkaListenerContainerFactoryWithCustomErrorHandler() {
this.contextRunner.withBean("errorHandler", ErrorHandler.class, () -> mock(ErrorHandler.class)) this.contextRunner.withBean("errorHandler", ErrorHandler.class, () -> mock(ErrorHandler.class))
.run((context) -> { .run((context) -> {
@ -522,6 +523,7 @@ class KafkaAutoConfigurationTests {
} }
@Test @Test
@Deprecated
void concurrentKafkaListenerContainerFactoryInBatchModeShouldUseBatchErrorHandler() { void concurrentKafkaListenerContainerFactoryInBatchModeShouldUseBatchErrorHandler() {
this.contextRunner.withBean("batchErrorHandler", BatchErrorHandler.class, () -> mock(BatchErrorHandler.class)) this.contextRunner.withBean("batchErrorHandler", BatchErrorHandler.class, () -> mock(BatchErrorHandler.class))
.withPropertyValues("spring.kafka.listener.type=batch").run((context) -> { .withPropertyValues("spring.kafka.listener.type=batch").run((context) -> {

View File

@ -1693,7 +1693,7 @@ bom {
] ]
} }
} }
library("Spring Kafka", "2.8.2") { library("Spring Kafka", "2.8.3-SNAPSHOT") {
group("org.springframework.kafka") { group("org.springframework.kafka") {
modules = [ modules = [
"spring-kafka", "spring-kafka",

View File

@ -42,7 +42,7 @@ The following component creates a listener endpoint on the `someTopic` topic:
include::code:MyBean[] include::code:MyBean[]
If a `KafkaTransactionManager` bean is defined, it is automatically associated to the container factory. If a `KafkaTransactionManager` bean is defined, it is automatically associated to the container factory.
Similarly, if a `RecordFilterStrategy`, `ErrorHandler`, `CommonErrorHandler`, `AfterRollbackProcessor` or `ConsumerAwareRebalanceListener` bean is defined, it is automatically associated to the default factory. Similarly, if a `RecordFilterStrategy`, `CommonErrorHandler`, `AfterRollbackProcessor` or `ConsumerAwareRebalanceListener` bean is defined, it is automatically associated to the default factory.
Depending on the listener type, a `RecordMessageConverter` or `BatchMessageConverter` bean is associated to the default factory. Depending on the listener type, a `RecordMessageConverter` or `BatchMessageConverter` bean is associated to the default factory.
If only a `RecordMessageConverter` bean is present for a batch listener, it is wrapped in a `BatchMessageConverter`. If only a `RecordMessageConverter` bean is present for a batch listener, it is wrapped in a `BatchMessageConverter`.