Skip to content

Commit 38aeee1

Browse files
authored
Fix documentation error: the comments were attached to the wrong functions (#150)
1 parent 2214f1f commit 38aeee1

File tree

1 file changed

+8
-8
lines changed

1 file changed

+8
-8
lines changed

kcbq-connector/src/main/java/com/wepay/kafka/connect/bigquery/config/BigQuerySinkConfig.java

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -1200,22 +1200,22 @@ public SchemaRetriever getSchemaRetriever() {
12001200
}
12011201

12021202
/**
1203-
* If the connector is configured to load Kafka data into BigQuery, this config defines
1204-
* the name of the kafka data field. A structure is created under the field name to contain
1205-
* kafka data schema including topic, offset, partition and insertTime.
1203+
* If the connector is configured to load Kafka keys into BigQuery, this config defines
1204+
* the name of the kafka key field. A structure is created under the field name to contain
1205+
* a topic's Kafka key schema.
12061206
*
1207-
* @return Field name of Kafka Data to be used in BigQuery
1207+
* @return Field name of Kafka Key to be used in BigQuery
12081208
*/
12091209
public Optional<String> getKafkaKeyFieldName() {
12101210
return Optional.ofNullable(getString(KAFKA_KEY_FIELD_NAME_CONFIG));
12111211
}
12121212

12131213
/**
1214-
* If the connector is configured to load Kafka keys into BigQuery, this config defines
1215-
* the name of the kafka key field. A structure is created under the field name to contain
1216-
* a topic's Kafka key schema.
1214+
* If the connector is configured to load Kafka data into BigQuery, this config defines
1215+
* the name of the kafka data field. A structure is created under the field name to contain
1216+
* kafka data schema including topic, offset, partition and insertTime.
12171217
*
1218-
* @return Field name of Kafka Key to be used in BigQuery
1218+
* @return Field name of Kafka Data to be used in BigQuery
12191219
*/
12201220
public Optional<String> getKafkaDataFieldName() {
12211221
return Optional.ofNullable(getString(KAFKA_DATA_FIELD_NAME_CONFIG));

0 commit comments

Comments
 (0)