Windows本地运行Kafka与Debezium PostgreSQL连接器报错求助

问题根源 #

Windows系统没有Linux默认的/tmp目录，而Kafka Connect单机模式默认用文件存储偏移量（offset），配置中指定的路径/tmp/connect.offsets在Windows下无效，导致找不到文件。

修复方案 #

方案1：修改偏移量存储文件路径（单机模式常用） #

1. 打开.\kafka\config\connect-standalone.properties配置文件
2. 找到offset.storage.file.filename配置项，将默认值替换为Windows合法路径，比如：

   # 示例1：使用C盘临时目录
   offset.storage.file.filename=C:/tmp/connect.offsets
   # 示例2：使用Kafka目录下的自定义tmp文件夹
   offset.storage.file.filename=./kafka/tmp/connect.offsets
   

3. 手动创建你指定的路径对应的文件夹（比如C:/tmp或./kafka/tmp）
4. 重启Kafka Connect进程：

   .\kafka\bin\windows\connect-standalone.bat .\kafka\config\connect-standalone.properties .\kafka\postgres-connector.properties
   

方案2：改用Kafka存储偏移量（更稳定） #

如果希望避免本地文件依赖，可将偏移量存储到Kafka集群中：

1. 同样打开connect-standalone.properties
2. 替换以下配置项：

   # 注释掉原有的文件存储配置
   # offset.storage.file.filename=/tmp/connect.offsets
   # 启用Kafka作为偏移量存储
   offset.storage=org.apache.kafka.connect.storage.KafkaOffsetBackingStore
   offset.storage.topic=connect-offsets
   offset.storage.replication.factor=1
   

3. 确保Kafka集群正常运行，重启Connect即可。

内容的提问来源于stack exchange，提问作者Sidhant Suvagiya