Skip to content

Commit b69a453

Browse files
committed
Upgrade dependencies & fix lambdas for method ref
1 parent 4390405 commit b69a453

File tree

2 files changed

+7
-7
lines changed

2 files changed

+7
-7
lines changed

build.gradle

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -72,18 +72,18 @@ subprojects { subproject ->
7272
googleJsr305Version = '3.0.2'
7373
hamcrestVersion = '1.3'
7474
hibernateValidationVersion = '6.0.12.Final'
75-
jacksonVersion = '2.9.6'
75+
jacksonVersion = '2.9.7'
7676
jaywayJsonPathVersion = '2.4.0'
7777
junit4Version = '4.12'
78-
junitJupiterVersion = '5.3.1'
79-
junitPlatformVersion = '1.3.1'
78+
junitJupiterVersion = '5.3.2'
79+
junitPlatformVersion = '1.3.2'
8080
kafkaVersion = '2.0.0'
8181
log4jVersion = '2.11.1'
82-
mockitoVersion = '2.22.0'
82+
mockitoVersion = '2.23.4'
8383
scalaVersion = '2.11'
8484
springRetryVersion = '1.2.2.RELEASE'
85-
springVersion = '5.1.2.RELEASE'
86-
springDataCommonsVersion = '2.1.2.RELEASE'
85+
springVersion = '5.1.3.RELEASE'
86+
springDataCommonsVersion = '2.1.3.RELEASE'
8787

8888
idPrefix = 'kafka'
8989

spring-kafka/src/main/java/org/springframework/kafka/listener/adapter/MessagingMessageListenerAdapter.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -433,7 +433,7 @@ private void sendReplyForMessageSource(Object result, String topic, Object sourc
433433
&& !key.startsWith(KafkaHeaders.RECEIVED);
434434
})
435435
.filter(e -> this.replyHeadersConfigurer.shouldCopy(e.getKey(), e.getValue()))
436-
.collect(Collectors.toMap(e -> e.getKey(), e -> e.getValue()));
436+
.collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
437437
if (headersToCopy.size() > 0) {
438438
builder.copyHeaders(headersToCopy);
439439
}

0 commit comments

Comments
 (0)