package com.wepay.kafka.connect.bigquery.convert;


/**
 *  Enum class for Kafka schema or record type, either value or key.
 */
public enum KafkaSchemaRecordType {
    VALUE("value"),
    KEY("key");
    String str;
    KafkaSchemaRecordType(String str) {
        this.str = str;
    }
    public String toString() {
        return this.str;
    }
}

@@ -158,16 +158,17 @@
 dType %7B%0A
+%0A
     VALU
@@ -195,20 +195,35 @@
 %22key%22);%0A
+%0A
     
+private final 
 String s
@@ -222,24 +222,25 @@
 String str;%0A
+%0A
     KafkaSch
@@ -297,16 +297,17 @@
 ;%0A    %7D%0A
+%0A
     publ

Modify KafkaSchemaRecordType.