From 6fed87bc0bda9de7e3a8673aa8dca746d49dbd63 Mon Sep 17 00:00:00 2001 From: Gary Russell Date: Fri, 29 Jan 2021 16:52:56 -0500 Subject: [PATCH] Fix previous commit --- .../springframework/kafka/core/DefaultKafkaConsumerFactory.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/spring-kafka/src/main/java/org/springframework/kafka/core/DefaultKafkaConsumerFactory.java b/spring-kafka/src/main/java/org/springframework/kafka/core/DefaultKafkaConsumerFactory.java index 1b024447..04363a07 100644 --- a/spring-kafka/src/main/java/org/springframework/kafka/core/DefaultKafkaConsumerFactory.java +++ b/spring-kafka/src/main/java/org/springframework/kafka/core/DefaultKafkaConsumerFactory.java @@ -257,7 +257,7 @@ public class DefaultKafkaConsumerFactory extends KafkaResourceFactory protected Consumer createKafkaConsumer(@Nullable String groupId, @Nullable String clientIdPrefixArg, @Nullable String clientIdSuffixArg, @Nullable Properties properties) { - boolean overrideClientIdPrefix = StringUtils.hasText(clientIdPrefix); + boolean overrideClientIdPrefix = StringUtils.hasText(clientIdPrefixArg); String clientIdPrefix = clientIdPrefixArg; String clientIdSuffix = clientIdSuffixArg; if (clientIdPrefix == null) {