This is an automated email from the ASF dual-hosted git repository.
frankvicky 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 d6fdbfcf15a MINOR: Fix typos in CoordinatorRecordTypeGenerator (#20549)
d6fdbfcf15a is described below
commit d6fdbfcf15adc279c6aabd6f630eada66f2dec41
Author: David Jacot <[email protected]>
AuthorDate: Thu Sep 18 10:22:35 2025 +0200
MINOR: Fix typos in CoordinatorRecordTypeGenerator (#20549)
This patch fixes a few typos in CoordinatorRecordTypeGenerator.
Reviewers: Chia-Ping Tsai <[email protected]>, TengYao Chi
<[email protected]>, Sean Quah <[email protected]>
---
.../java/org/apache/kafka/message/CoordinatorRecordTypeGenerator.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/generator/src/main/java/org/apache/kafka/message/CoordinatorRecordTypeGenerator.java
b/generator/src/main/java/org/apache/kafka/message/CoordinatorRecordTypeGenerator.java
index 5a7ce9c1307..5e7089d280d 100644
---
a/generator/src/main/java/org/apache/kafka/message/CoordinatorRecordTypeGenerator.java
+++
b/generator/src/main/java/org/apache/kafka/message/CoordinatorRecordTypeGenerator.java
@@ -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++;