File tree Expand file tree Collapse file tree 3 files changed +1
-3
lines changed
src/main/java/com/wepay/kafka/connect/bigquery/config Expand file tree Collapse file tree 3 files changed +1
-3
lines changed Original file line number Diff line number Diff line change @@ -20,7 +20,6 @@ tasks.max=1
20
20
topics =kcbq-quickstart
21
21
sanitizeTopics =true
22
22
23
- autoCreateTables =true
24
23
autoUpdateSchemas =true
25
24
26
25
schemaRetriever =com.wepay.kafka.connect.bigquery.schemaregistry.schemaretriever.SchemaRegistrySchemaRetriever
Original file line number Diff line number Diff line change @@ -214,7 +214,7 @@ public class BigQuerySinkConfig extends AbstractConfig {
214
214
215
215
public static final String TABLE_CREATE_CONFIG = "autoCreateTables" ;
216
216
private static final ConfigDef .Type TABLE_CREATE_TYPE = ConfigDef .Type .BOOLEAN ;
217
- public static final boolean TABLE_CREATE_DEFAULT = false ;
217
+ public static final boolean TABLE_CREATE_DEFAULT = true ;
218
218
private static final ConfigDef .Importance TABLE_CREATE_IMPORTANCE = ConfigDef .Importance .HIGH ;
219
219
private static final String TABLE_CREATE_DOC =
220
220
"Automatically create BigQuery tables if they don't already exist" ;
Original file line number Diff line number Diff line change @@ -17,7 +17,6 @@ name=bigquery-connector
17
17
connector.class =com.wepay.kafka.connect.bigquery.BigQuerySinkConnector
18
18
tasks.max =1
19
19
20
- autoCreateTables =true
21
20
autoUpdateSchemas =true
22
21
23
22
sanitizeTopics =true
You can’t perform that action at this time.
0 commit comments