Spring/spring-kafka
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix previous commit

Browse Source
This commit is contained in:
Gary Russell
2021-01-29 16:52:56 -05:00
parent 10cb5e42ed
commit 6fed87bc0b
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-kafka/src/main/java/org/springframework/kafka/core/DefaultKafkaConsumerFactory.java
View File

@@ -257,7 +257,7 @@ public class DefaultKafkaConsumerFactory<K, V> extends KafkaResourceFactory
protected Consumer<K, V> 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) {