Kafka Connect添加db.timezone属性后找不到ZoneRules提供程序

Question

我正在分布式模式下运行Kafka Connect（Confluent），最近添加了数据库。timezone属性设置为JDBC源连接器。这样做之后，当我加载连接器时，会看到以下错误：

java.lang.NoClassDefFoundError:无法初始化Java . time . zone . zonerulesprovider类\ n \ tat Java . time . zoneregion . ofid(zoneregion . Java:120)\ n \ tat Java . time . zoneid . of(zoneid . Java:411)

这是从JDBCSourceConnectorConfig中的以下代码中发生的：

https://github.com/confluentinc/kafka-connect-jdbc/blob/master/src/main/java/io/confluent/connect/jdbc/source/JdbcSourceConnectorConfig.java#L807

如果我登录到Kafka Connect框并运行java-version，我会得到：

openjdk version "1.8.0_262"
OpenJDK Runtime Environment (build 1.8.0_262-b10)
OpenJDK 64-Bit Server VM (build 25.262-b10, mixed mode)

如果我创建一个如下所示的小型 Java 程序并在该框上运行它，它可以正常工作：

import java.time.ZoneId;
import java.time.zone.ZoneRulesProvider;
import java.util.TimeZone;

public class TestTime {
  public static void main(String[] args) {
    String dbTimeZone = "America/New_York";
    System.out.println(TimeZone.getTimeZone(ZoneId.of(dbTimeZone)));
    System.out.println(ZoneRulesProvider.getAvailableZoneIds());
  }
}

那么为什么 confluent/kafka 连接会中断呢？为什么它找不到ZoneRulesProvider？

Answer 1

在我的服务器上重新启动kafka连接后，这个问题似乎已经消失了。