开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

flink 中我现在有两个zookeeper 一个连接kafka用的zookeeper 需要配置?

flink 中我现在有两个zookeeper 一个连接kafka用的zookeeper 需要配置zookeeper.sasl.client=false,还有一个hbase 用的zookeeper 需要配置zookeeper.sasl.client=true 这样怎么配置才能一起用啊?

展开
收起
真的很搞笑 2023-06-11 22:13:57 143 0
1 条回答
写回答
取消 提交回答
  • Flink 中如果你有两个 ZooKeeper,一个连接 Kafka 用的 ZooKeeper 需要配置 zookeeper.sasl.client=false,还有一个 HBase 用的 ZooKeeper 需要配置 zookeeper.sasl.client=true,你可以尝试以下方法来解决这个问题:

    • 你可以使用不同的 JAAS 配置文件来分别指定 Kafka 和 HBase 的 ZooKeeper 客户端的 SASL 认证参数¹²。例如,你可以创建两个 JAAS 配置文件,分别命名为 kafka_jaas.conf 和 hbase_jaas.conf,并在其中设置 zookeeper.sasl.client 为 false 或 true。
    • 你可以在启动 Flink 应用时,使用 -Djava.security.auth.login.config 参数来指定不同的 JAAS 配置文件。例如,你可以使用以下命令来启动 Flink 应用:
    # 使用 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
    
    • 你也可以在 Flink 应用的代码中,使用 System.setProperty 方法来动态地设置不同的 JAAS 配置文件。例如,你可以在 Flink 应用的 main 方法中,根据不同的场景,使用以下代码来设置 JAAS 配置文件:

    ```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");

    2023-10-16 11:50:20
    赞同 1 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载