ssage_ = input.readMessage(io.confluent.kafka.serializers.protobuf.test.TestMessageProtos.TestMessage.parser(), extensionRegistry);               if (subBuilder != null) {                 subBuilder.mergeFrom(