我想安装Apache Kafka,但一直在安装Zookeeper
我提取了所有的文件并创建了环境变量,现在它在“Zookeeper审计被禁用”后停止工作了。
现在看完这些链接后,
我更新了两个文件(skServer.cmd和conf/zoo.cfg)。在skServer中添加一行“-Dzookeeper.audit.enable=true”。conf/zoo.cfg中的cmd文件和“audit.enable=true”。
现在输出已更改为“Zookeeper 审核已启用”,但它仍然不执行任何操作,并且像以前一样停止。
运行zkServer命令并编辑文件后的输出
甚至尝试一次更改一个文件,但输出相同,仍然无法工作。
有人能帮我理解这个问题并提供解决方案吗?非常感谢你。
动物园管理员服务器启动
或zkServer。根据设计,cmd
不返回。它正在跟踪日志并等待客户端连接
您必须启动第二个终端来运行Kafka代理,如Kafka文档中所述
分布式 Apache HBase 安装依赖于正在运行的 ZooKeeper 集群。所有参与节点和客户端都需要能够访问正在运行的 ZooKeeper 集合。 Apache HBase 默认为您管理 ZooKeeper“集群”。它将启动和停止 ZooKeeper 集合作为 HBase 启动/停止过程的一部分。您还可以独立于 HBase 管理 ZooKeeper 集合,只需将 HBase 指向它应该使用
我必须采用4.3.1单solr索引并将其迁移到solrcloud 5.2.1 新的5.2.1体系结构是2个碎片,每个碎片有1个主碎片和1个从碎片(副本)。我的步骤是: 设置新的单分片solrcloud 5.2.1 我也有配置在一个单一的ZooKeeper(我知道1 ZK不推荐)。 一切正常,碎片正在运行,副本包含数据,我可以从新的solrcloud 5.2.1 2碎片中查询数据。 当我添加新文档时
我正在为Storm开发代码,这是开发人员的一个示例。我的问题是,当您从IDE Eclipse运行此代码时,不会建立Storm和ZooKeer之间的连接。ZooKeer在2181中运行,也设置在storm.yaml. 我的例外是: 有什么想法或程序要执行吗?是否从配置代码中传递?和我一样?
假设我有 3 台 Kafka 服务器。服务器 1 zoopkeeper1 服务器 2 zoopkeeper2 服务器 3 zoopkeeper3 在集群配置中,zoopkeepers 会发生什么?它们是为每个服务器单独维护的,还是会在群集配置中同步其数据?
在Zookeeper和代理身份验证上启用SASL时,我面临以下错误。 以下配置在JAAS文件中给出,该文件作为KAFKA_OPTS传递,将其作为JVM参数:- Kafka经纪人的服务器。属性设置了以下额外字段:- Zookeeper属性如下所示:
如果我部署war,我将得到以下异常: 原因:org.apache.camel.resolveEndpointFailedException:无法解析endpoint:kafka://localhost:9092?serializerClass=kafka.serializer.stringencoder&topic=checking&zookeePerhost=localhost&zookeePe