flink 中我现在有两个zookeeper 一个连接kafka用的zookeeper 需要配置zookeeper.sasl.client=false,还有一个hbase 用的zookeeper 需要配置zookeeper.sasl.client=true 这样怎么配置才能一起用啊?
Flink 中如果你有两个 ZooKeeper,一个连接 Kafka 用的 ZooKeeper 需要配置 zookeeper.sasl.client=false,还有一个 HBase 用的 ZooKeeper 需要配置 zookeeper.sasl.client=true,你可以尝试以下方法来解决这个问题:
# 使用 kafka_jaas.conf 来连接 Kafka 的 ZooKeeper
flink run -Djava.security.auth.login.config=kafka_jaas.conf -c com.example.FlinkKafkaJob your-flink-job.jar
# 使用 hbase_jaas.conf 来连接 HBase 的 ZooKeeper
flink run -Djava.security.auth.login.config=hbase_jaas.conf -c com.example.FlinkHBaseJob your-flink-job.jar
```java
// 使用 kafka_jaas.conf 来连接 Kafka 的 ZooKeeper
System.setProperty("java.security.auth.login.config", "kafka_jaas.conf");
// 使用 hbase_jaas.conf 来连接 HBase 的 ZooKeeper
System.setProperty("java.security.auth.login.config", "hbase_jaas.conf");
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。