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.
2 parents ae67984 + 6e9c7a3 commit efbd6fbCopy full SHA for efbd6fb
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