diff --git a/clients/src/test/java/org/apache/kafka/common/message/SimpleExampleMessageTest.java b/clients/src/test/java/org/apache/kafka/common/message/SimpleExampleMessageTest.java index 5b652748eb2..fb8b0161c2e 100644 --- a/clients/src/test/java/org/apache/kafka/common/message/SimpleExampleMessageTest.java +++ b/clients/src/test/java/org/apache/kafka/common/message/SimpleExampleMessageTest.java @@ -419,4 +419,26 @@ public class SimpleExampleMessageTest { assertEquals(message.hashCode(), messageFromJson.hashCode()); } + @Test + public void testToString() { + SimpleExampleMessageData message = new SimpleExampleMessageData(); + message.setMyUint16(65535); + message.setTaggedUuid(Uuid.fromString("x7D3Ck_ZRA22-dzIvu_pnQ")); + message.setMyFloat64(1.0); + assertEquals("SimpleExampleMessageData(processId=AAAAAAAAAAAAAAAAAAAAAA, " + + "myTaggedIntArray=[], " + + "myNullableString=null, " + + "myInt16=123, myFloat64=1.0, " + + "myString='', " + + "myBytes=[], " + + "taggedUuid=x7D3Ck_ZRA22-dzIvu_pnQ, " + + "taggedLong=914172222550880202, " + + "zeroCopyByteBuffer=java.nio.HeapByteBuffer[pos=0 lim=0 cap=0], " + + "nullableZeroCopyByteBuffer=java.nio.HeapByteBuffer[pos=0 lim=0 cap=0], " + + "myStruct=MyStruct(structId=0, arrayInStruct=[]), " + + "myTaggedStruct=TaggedStruct(structId=''), " + + "myCommonStruct=TestCommonStruct(foo=123, bar=123), " + + "myOtherCommonStruct=TestCommonStruct(foo=123, bar=123), " + + "myUint16=65535)", message.toString()); + } } diff --git a/generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java b/generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java index e34c784a1ab..e8181eab79c 100644 --- a/generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java +++ b/generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java @@ -1900,9 +1900,8 @@ public final class MessageDataGenerator implements MessageClassGenerator { } else if (field.type().isRecords()) { buffer.printf("+ \"%s%s=\" + %s%n", prefix, field.camelCaseName(), field.camelCaseName()); - } else if (field.type().isStruct() || - field.type() instanceof FieldType.UUIDFieldType) { - } else if (field.type().isStruct()) { + } else if (field.type() instanceof FieldType.UUIDFieldType || + field.type().isStruct()) { buffer.printf("+ \"%s%s=\" + %s.toString()%n", prefix, field.camelCaseName(), field.camelCaseName()); } else if (field.type().isArray()) {