《zookeeper》专题

我想将数据从数据仓库摄取到kafka中，然后将avro记录存储到mySQL RDMS中。我想消除对动物园管理员的依赖。不使用动物园管理员可以做到这一点吗？

我是apache kafka的新手，我已经在自己部署的kubernetes集群上用zookeeper建立了一个kafka-broker。（2个独立的吊舱） 没有明显的错误日志，一切正常，包括： null 在kafka偏移量监视工具中列出活动使用者 当我尝试在zookeeper CLI中列出活动使用者或在监控工具中查看活动使用者时，我也得到了空的结果。（当我有一个使用者会话运行时，如上所述） zoo

我读过消费控制台中的线程boostrap-server vs zookeeper，但我不清楚这一点。 我的疑问是，假设我们有zookeeper在localhost:2181上运行，三个代理服务器在localhost:9092、localhost:9093、localhost:9094上运行，我们有一个主题my_topic与分区3和replication1，主题由代理共享，因为它有三个分区。 在Ap

启动使用者接收消息 根据我的理解，consumer直接使用来自broker的消息，但在上面的consumer命令中，我们没有提到broker，而只提到zookeeper。消费者是否会连接到zookeeper（而不是broker）来消费消息？

我试图删除一个包含8个分区和2个复制的Kafka主题。首先，我使用Kafka主题删除该主题。sh——删除命令。然后我使用了zkCli。sh-服务器从属1。。。。。slave3和rmr/brokers/topics/MY_主题。 然而我仍然看到这个话题在 /brokers/topics/.我试着重启Kafka，一切都一样。 顺便说一句，具有1个分区和1个副本的主题可以成功删除。

我正在尝试用3个代理&Zookeeper来测试运行一个单独的Kafka节点。我希望使用控制台工具进行测试。我是这样管理制作人的： 然后我以这样的方式运行消费者： 我可以在生产者中输入消息，并在消费者中看到它们，这是预期的。但是，当我使用bootstrap-server运行消费者的更新版本时，我什么也得不到。例如： 当我有一个代理在端口9092上运行时，这工作得很好，所以我彻底搞糊涂了。有没有办法让

根据这两个教程：即教程1和教程2，我能够在完全分布式模式下设置HBase集群。最初，集群似乎工作正常。 hmaster/Name节点中的“jps”输出 datanodes/RegionServers中的jps输出 null （我已经试着在/etc/hosts/中评论与HBase相关的主机，但仍然没有成功） 在hbase-site.xml中

我是Apache ZooKeeper概念的新手，它使用netflix ribbon客户端实现服务发现和负载平衡。我在github中看到了一些示例(https://github.com/spring-cloud/spring-cloud-zookeeper ). 有人能帮助我了解如何在应用服务实例上设置ZooKeeper和服务发现实现吗。我很想知道这个概念。 提前感谢…，

当通过作为docker映像部署在localhost上时，它都可以正常工作，但当作为单独的任务/服务部署到AWS ECS时（使用)，两者之间的通信不再工作，并且假客户机错误如下： 注意，这里的响应有点像标准的Tomcat404响应。 我已经看到这个AWS部署在Zookeeper中存储的值，它似乎将IP地址作为的值，我不确定这是否正确。 此IP地址既不匹配与ECS任务关联的ENI的公共IP也不匹配EN

我遵循了这个问题答案的教程：Kafka SASL动物园管理员身份验证 并且我设置了zookeeper.set。acl在服务器中为true。属性，但我仍然可以访问2181端口上的动物园管理员，任何人都可以通过：

我使用的是Kafka版本0.10.1。我通过SSL及其工作fine.Now连接了Kafka经纪人及其客户。我有一个查询，但有一些限制。我的限制是 不允许纯文本通信 Kafka经纪人与其客户之间的连接是SSL Kafka经纪人和动物园管理员之间通过SASL的连接（因为动物园管理员不支持SSL） 由于所有代理间通信都设置为 SSL。我有一个疑问，动物园管理员和Kafka经纪人之间的SASL连接是否可能

我可以做DIGEST-MD5认证与Kafka代理和嵌入式zookeeper这是由Kafka，但我得到以下错误消息，而做DIGEST-MD5认证与Kafka代理和非嵌入式zookeeper（单独的zookeeper实例）。 请在下面找到错误消息：

我正在尝试使用来启动zk/kafka。 zookeeper-1 _ 1 |[2022-01-17 12:30:34，845]信息绑定到端口0 . 0 . 0 . 0/0 . 0 . 0:2181 (org.apache.zookeeper . server . nettyservercnxnfactory)< br > zookeeper-1 _ 1 |[2022-01-17 12:30:34，8

我按照以下说明设置了一个多节点kafka集群。现在，如何连接到动物园管理员？在JAVA中，只连接一个来自生产者/消费者端的动物园管理员可以吗？或者有办法连接所有的动物园管理员节点吗？ 设置多节点阿帕奇动物园守护者集群 在集群的每个节点上，将以下行添加到文件kafka/config/zookeeper.properties中 在群集的每个节点上，在由 dataDir 属性表示的文件夹中创建一个名为

在尝试使用下面提到的 createTopics 函数创建主题时，我在多节点 kafka 集群中遇到了“复制因子：1 大于可用代理：多节点集群上的 0”。我有 3 个 kafka 代理，我尝试为每个主题创建 2 个分区，并将复制因子保持在 1。不知道为什么得到这个错误。在单节点设置（1个动物园管理员和1个kafka经纪人）中，这同样可以很好地工作。 非常感谢任何帮助/ 错误: 我按照以下说明设置了一