创建KSQL流报org.xerial.snappy.Snappy初始化失败问题咨询

执行如下创建流语句时触发报错：

create stream s1 with (kafka_topic = 'T3_NON_END', value_format = 'avro');

报错信息如下：

java.lang.NoClassDefFoundError: Could not initialize class org.xerial.snappy.Snappy

报错原因 #

Snappy压缩库默认会向/tmp目录写入native二进制临时文件并尝试执行，当/tmp目录挂载时设置了noexec权限时，就会触发上述初始化失败报错，需要自定义指定Snappy可写入执行的临时目录路径。

配置方法 #

注意提前创建自定义临时目录，并给KSQL运行用户授予该目录的读写执行权限，可根据部署场景选择对应配置方式：

方式1：临时启动KSQL服务时指定 #

在启动KSQL服务前先设置环境变量即可：

export KSQL_OPTS="-Dorg.xerial.snappy.tempdir=/your/custom/executable/tmpdir"
# 后续正常执行KSQL服务启动命令即可

方式2：修改配置文件持久生效 #

1. 找到KSQL服务的环境变量配置文件，默认路径通常为/etc/ksqldb/ksql-server-env.sh，不同版本部署路径可能存在差异
2. 在配置文件末尾追加如下内容：

export KSQL_OPTS="$KSQL_OPTS -Dorg.xerial.snappy.tempdir=/your/custom/executable/tmpdir"

3. 保存配置后重启KSQL服务即可生效

方式3：KSQL CLI调试临时指定 #

如果仅在本地使用CLI连接远端服务排查问题，可以在启动CLI时直接传入参数：

ksql -Dorg.xerial.snappy.tempdir=/your/custom/executable/tmpdir <KSQL服务访问地址>

内容的提问来源于stack exchange，提问作者Dave Stiles