root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 5 Packages Projects Releases Wiki Activity

MINOR: Fix typos in CoordinatorRecordTypeGenerator (#20549) 

This patch fixes a few typos in CoordinatorRecordTypeGenerator.

Reviewers: Chia-Ping Tsai <chia7712@gmail.com>, TengYao Chi
 <frankvicky@apache.org>, Sean Quah <squah@confluent.io>
This commit is contained in:
David Jacot 2025-09-18 10:22:35 +02:00 committed by GitHub
parent 04b4a8f571
commit d6fdbfcf15
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
generator/src/main/java/org/apache/kafka/message/CoordinatorRecordTypeGenerator.java
View File

@ -124,11 +124,11 @@ public class CoordinatorRecordTypeGenerator implements TypeClassGenerator {
for (Map.Entry<Short, CoordinatorRecord> entry : records.entrySet()) {
MessageSpec key = entry.getValue().key;
if (key == null) {
throw new RuntimeException("Coordinator record " + entry.getKey() + " has not key.");
throw new RuntimeException("Coordinator record " + entry.getKey() + " has no key.");
}
MessageSpec value = entry.getValue().value;
if (value == null) {
throw new RuntimeException("Coordinator record " + entry.getKey() + " has not key.");
throw new RuntimeException("Coordinator record " + entry.getKey() + " has no value.");
}
String name = cleanName(key.name());
numProcessed++;