This is an automated email from the ASF dual-hosted git repository.
chia7712 pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 21340a4d138 KAFKA-20638 Use Locale.ROOT in
ConsumerGroupCommand.toLowerCase() (#22415)
21340a4d138 is described below
commit 21340a4d1381ed3f388af2880b0e045b551a5a91
Author: Kenan Adel <[email protected]>
AuthorDate: Sat May 30 06:54:03 2026 +0300
KAFKA-20638 Use Locale.ROOT in ConsumerGroupCommand.toLowerCase() (#22415)
Fixes a checkstyle violation by explicitly passing
`java.util.Locale.ROOT` to `toLowerCase()` inside
`ConsumerGroupCommand.consumerGroupTypesFromString()`.
This ensures consistent behavior across different server locales.
Reviewers: Chia-Ping Tsai <[email protected]>
---
.../org/apache/kafka/tools/consumer/group/ConsumerGroupCommand.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/tools/src/main/java/org/apache/kafka/tools/consumer/group/ConsumerGroupCommand.java
b/tools/src/main/java/org/apache/kafka/tools/consumer/group/ConsumerGroupCommand.java
index 895ce1eaba1..f8705c9e7a4 100644
---
a/tools/src/main/java/org/apache/kafka/tools/consumer/group/ConsumerGroupCommand.java
+++
b/tools/src/main/java/org/apache/kafka/tools/consumer/group/ConsumerGroupCommand.java
@@ -164,7 +164,7 @@ public class ConsumerGroupCommand {
@SuppressWarnings("Regexp")
static Set<GroupType> consumerGroupTypesFromString(String input) {
Set<GroupType> validTypes = Set.of(GroupType.CLASSIC,
GroupType.CONSUMER);
- Set<GroupType> parsedTypes =
Stream.of(input.toLowerCase().split(",")).map(s ->
GroupType.parse(s.trim())).collect(Collectors.toSet());
+ Set<GroupType> parsedTypes =
Stream.of(input.toLowerCase(java.util.Locale.ROOT).split(",")).map(s ->
GroupType.parse(s.trim())).collect(Collectors.toSet());
if (!validTypes.containsAll(parsedTypes)) {
throw new IllegalArgumentException("Invalid types list '" + input
+ "'. Valid types are: " +
String.join(", ",
validTypes.stream().map(GroupType::toString).collect(Collectors.toSet())));