kafka JDBC Sink Connector 是否跟踪加载到目标数据库的数据？答案

【问题标题】：Does kafka JDBC Sink Connector keeps track of data being loaded to destination database?kafka JDBC Sink Connector 是否跟踪加载到目标数据库的数据？
【发布时间】：2020-07-14 21:06:57
【问题描述】：

我正在使用 kafka jdbc sink 连接器，它将数据从主题插入 SQL Server 数据库。由于 mssql 连接器中的一些问题因错误而停止：

Caused by: org.apache.kafka.connect.errors.ConnectException: com.microsoft.sqlserver.jdbc.SQLServerException: The TCP/IP connection to the host mssql_ip , port 1433 has failed. Error: "connect timed out.

我的问题是，我当前的数据会在 SQL Server 启动后插入到它吗？或者它会从那个时间点开始插入数据？

【问题讨论】：

标签： sql-server jdbc apache-kafka apache-kafka-connect confluent-platform

【解决方案1】：

当 SQL Server 启动并可用时，Kafka Connect JDBC 接收器连接器将向其发送数据。

如果出现问题（网络出现故障、SQL Server 停止等），Kafka Connect 将知道它在发送的主题（偏移量）中的位置，然后从该点开始下一步重新启动连接器的时间。

如果 SQL Server 已关闭，Kafka Connect 无法向其发送数据。 SQL Server 启动后，您需要重新启动 Kafka Connect 连接器任务，然后它将再次开始发送数据。

【讨论】：