如何解决Kafka 集成测试,无法设置 SASL 启用机制
我正在使用 TestContainers
进行集成测试并尝试启用 SASL,以便我可以保留相同的配置文件而不是重复的代码。
public static KafkaContainer kafka =
new KafkaContainer(DockerImageName.parse(KAFKA_TEST_IMAGE))
.withNetwork(Network.newNetwork())
.withEnv("KAFKA_AUTO_CREATE_TOPICS_ENABLE","false")
.withEnv("KAFKA_ALLOW_EVERYONE_IF_NO_ACL_FOUND","true")
.withEnv("KAFKA_SUPER_USERS","User:OnlySuperUser")
// .withEnv("KAFKA_CFG_SASL_ENABLED_MECHANISMS","PLAIN")
// .withEnv("KAFKA_CFG_SASL_MECHANISM_INTER_BROKER_PROTOCOL","SASL_PLAINTEXT")
.withEnv("KAFKA_SASL_ENABLED_MECHANISMS","PLAIN,SASL_PLAINTEXT")
.withEnv("KAFKA_SASL_JAAS_CONFIG",JAAS_CONFIG);
这是我正在玩的,但出现以下错误:
org.apache.kafka.common.errors.IllegalSaslStateException: Unexpected handshake request with client mechanism PLAIN,enabled mechanisms are []
似乎启用机制 (PLAIN) 被完全忽略了。为什么是这样?我查看了文档,但没有看到如何在容器中配置它。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。