Skip to content

Commit 25ad35e

Browse files
author
Bingqin Zhou
committed
Modify KafkaSchemaRecordType.
1 parent e6686cf commit 25ad35e

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

kcbq-connector/src/main/java/com/wepay/kafka/connect/bigquery/convert/KafkaSchemaRecordType.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,12 +5,16 @@
55
* Enum class for Kafka schema or record type, either value or key.
66
*/
77
public enum KafkaSchemaRecordType {
8+
89
VALUE("value"),
910
KEY("key");
10-
String str;
11+
12+
private final String str;
13+
1114
KafkaSchemaRecordType(String str) {
1215
this.str = str;
1316
}
17+
1418
public String toString() {
1519
return this.str;
1620
}

0 commit comments

Comments
 (0)