Skip to content

Commit 6fc8ce4

Browse files
committed
Resolve new Sonar issues
1 parent 8347b95 commit 6fc8ce4

File tree

2 files changed

+5
-3
lines changed

2 files changed

+5
-3
lines changed

spring-kafka/src/main/java/org/springframework/kafka/support/serializer/JsonDeserializer.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -335,6 +335,10 @@ public void configure(Map<String, ?> configs, boolean isKey) {
335335
if (configs.containsKey(REMOVE_TYPE_INFO_HEADERS)) {
336336
this.removeTypeHeaders = Boolean.parseBoolean(configs.get(REMOVE_TYPE_INFO_HEADERS).toString());
337337
}
338+
setUpTypeMethod(configs, isKey);
339+
}
340+
341+
private void setUpTypeMethod(Map<String, ?> configs, boolean isKey) {
338342
if (isKey && configs.containsKey(KEY_TYPE_METHOD)) {
339343
setUpTypeFuntion((String) configs.get(KEY_TYPE_METHOD));
340344
}

spring-kafka/src/main/java/org/springframework/kafka/support/serializer/ParseStringDeserializer.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -88,10 +88,8 @@ public void configure(Map<String, ?> configs, boolean isKey) {
8888
String parserMethod = (String) configs.get(isKey ? KEY_PARSER : VALUE_PARSER);
8989
Assert.state(parserMethod != null,
9090
"A parser must be provided either via a constructor or consumer properties");
91-
BiFunction<String, Headers, T> parser;
92-
parser = SerializationUtils.propertyToMethodInvokingFunction(parserMethod, String.class,
91+
this.parser = SerializationUtils.propertyToMethodInvokingFunction(parserMethod, String.class,
9392
getClass().getClassLoader());
94-
this.parser = parser;
9593
}
9694
}
9795

0 commit comments

Comments
 (0)