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 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++;