@@ -424,11 +424,14 @@ The following configuration items apply to TDengine Sink Connector and TDengine
...
@@ -424,11 +424,14 @@ The following configuration items apply to TDengine Sink Connector and TDengine
### TDengine Source Connector specific configuration
### TDengine Source Connector specific configuration
1.`connection.database`: source database name, no default value.
1.`connection.database`: source database name, no default value.
2.`topic.prefix`: topic name prefix after data is imported into kafka. Use `topic.prefix` + `connection.database` name as the full topic name. Defaults to the empty string "".
2.`topic.prefix`: topic name prefix used when importing data into kafka. Its defaults value is empty string "".
3.`timestamp.initial`: Data synchronization start time. The format is 'yyyy-MM-dd HH:mm:ss'. Default "1970-01-01 00:00:00".
3.`timestamp.initial`: Data synchronization start time. The format is 'yyyy-MM-dd HH:mm:ss'. If it is not set, the data importing to Kafka will be started from the first/oldest row in the database.
4.`poll.interval.ms`: Pull data interval, the unit is ms. Default is 1000.
4.`poll.interval.ms`: The time interval for checking newly created tables or removed tables, default value is 1000.
5.`fetch.max.rows`: The maximum number of rows retrieved when retrieving the database. Default is 100.
5.`fetch.max.rows`: The maximum number of rows retrieved when retrieving the database, default is 100.
6.`out.format`: The data format. The value could be line or json. The line represents the InfluxDB Line protocol format, and json represents the OpenTSDB JSON format. Default is `line`.
6.`out.format`: The data format. The value could be `line`, which represents the InfluxDB Line protocol format.
7. 7. `query.interval.ms`: The time range of reading data from TDengine each time, its unit is millisecond. It should be adjusted according to the data flow in rate, the default value is 1000.
8.`topic.per.stable`: If it's set to true, it means one super table in TDengine corresponds to a topic in Kafka, the topic naming rule is `<topic.prefix>-<connection.database>-<stable.name>`; if it's set to false, it means the whole DB corresponds to a topic in Kafka, the topic naming rule is `<topic.prefix>-<connection.database>`.