我正在启动一个kafka,我需要在启动时通过一个环境变量(或其他一些方法)来设置属性sasl.enabled.mechanisms
,而不是通过启动时使用的配置文件。
我尝试了环境变量KAFKA_SASL_ENABLED_MECHANISMS
,但没有捕获它。我也尝试过通过KAFKA_OPTS= -Dsasl.enabled.mechanisms=PLAIN
,但它也没有被捕获。
我知道这两种尝试都不起作用,因为我在连接到代理:org.apache.kafka.common.errors.IllegalSaslStateException: Unexpected handshake request with client mechanism PLAIN, enabled mechanisms are []
时一直收到这个错误。
有什么办法能满足我的需要吗?
发布于 2021-04-10 13:46:30
JVM标志不会传递给代理配置
如果要使用环境变量,则必须在启动代理之前注入一些模板处理,类似于Kafka Docker容器的工作情况。
您可以修改或包装kafka-server-start
来读取环境并重写配置文件。
https://stackoverflow.com/questions/67022702
复制相似问题