We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ae67984 commit 6e9c7a3Copy full SHA for 6e9c7a3
kcbq-connector/src/main/java/com/wepay/kafka/connect/bigquery/SchemaManager.java
@@ -38,6 +38,10 @@ public class SchemaManager {
38
* given table.
39
* @param schemaConverter Used to convert Kafka Connect Schemas into BigQuery format.
40
* @param bigQuery Used to communicate create/update requests to BigQuery.
41
+ * @param kafkaKeyFieldName The name of kafka key field to be used in BigQuery.
42
+ * If set to null, Kafka Key Field will not be included in BigQuery.
43
+ * @param kafkaDataFieldName The name of kafka data field to be used in BigQuery.
44
+ * If set to null, Kafka Data Field will not be included in BigQuery.
45
*/
46
public SchemaManager(
47
SchemaRetriever schemaRetriever,
0 commit comments