将Kafka server和client的启动脚本中的JAVA_HOME设置为Java 11或Java 16版本。
从Confluent的Maven仓库下载Confluent 7.2.1或更高版本,该版本已支持Java 17。
代码示例:
在Kafka server启动脚本中,将JAVA_HOME设置为Java 11或Java 16的路径:
export JAVA_HOME=
在Kafka client启动脚本中,将JAVA_HOME设置为Java 11或Java 16的路径:
export JAVA_HOME=
如果要继续使用Java 17,请将Confluent升级到7.2.1或更高版本。具体步骤:
在项目的Maven依赖中,添加Confluent 7.2.1或更高版本的依赖项:
io.confluent
kafka-streams
7.2.1
在Kafka server和client的启动脚本中,将JAVA_HOME设置为Java 17的路径:
export JAVA_HOME=