我在以下位置安装了Kafka 可以看出,目录名不包括版本(谷歌搜索告诉删除目录名中的版本)。 我仍然面对这个问题。
设置 我在端口8082上有一个正在运行的服务器(wilfly swarm,keycloack authenticated),它承载了我的日志功能。我可以通过REST将日志线推送到这个服务器。在幕后,Kafka的制作人正在运行和传播给Kafka的信息。 我在2181口有动物园管理员 我有一个代理在端口9092运行 日志服务器在端口8082上运行 当我试图通过Java生成器(和控制台生成器)生成消息时
我正在使用Docker启动一个kafka代理集群(例如,5个代理,每个容器一个代理)。Kafka版本2.12-0.11.0.0,动物园管理员3.4.10。 场景: null > 在独立模式下启动Zookeeper,然后启动kafka 创建主题 null 检查邮件 消息被累犯 null null server.properties(broker.id唯一,broker_ip:broker_port对
这就是我如何开始我的3个Kafka节点: 动物园管理员和Kafka集群在独立测试时表现良好。 我的意思是,我可以连接到一个Zookeeper节点(比如zoo1),并创建一个zNode。我可以在之后停止节点(例如,docker停止zoo1),并且我仍然可以从Zookeeper集群中的任何其他节点查询znode。 我将收到一个未知的HostException: 但是,我确实需要Kafka集群能够充分发
我试图使用docker容器实现一个由三个kafka服务器节点和三个zookeeper服务器节点组成的kafka集群,下面哪一个是首选的,或者如果两者都不是,首选的方式是什么? null
我在图像中有一个正在运行的Zookeeper实例和我的撰写文件: 当然,在防火墙中启用了端口: 我可以连接到正在运行的容器: 并查看服务器状态: 这似乎是一个已知的问题。 这会不会和我的封闭港口问题有关? 更新:我还尝试将属性作为添加到Compose文件中,并在文件中添加条目,但是命令仍然显示一个关闭的端口。
我不明白我做错了什么。有人能帮忙吗。我成功地能够在Linux“bin/zookeeper-server-start.sh config/zookeeper.properties”中启动zookeeper和kafka服务器。
对集群设置有点困惑: > Zookeeper可以通过配置myid(1,2,3...)将其设置为群集例如,在zoo.cfg文件中具有zookeeper1:2888:3888、zookeeper2:2889:3889 对于Kafka,在server.properties文件中,是否必须为参数zookeeper.connect指定zookeeper服务器的完整列表,还是只要1就足够了?有什么不同吗?我见
我是Kafka的初学者 1/我下载了Kafka的1.0.0版本 2/I更改了bith server.properties和zookeeper.properties中的数据目录位置属性 你能帮帮我吗?
null 编辑这里是答案
警告会话0x0,因为服务器空、意外错误、关闭套接字连接并试图重新连接(org.apache.zookeeper.clientcnxn)java.net.ConnectException:连接被拒绝 zookeeper首先开始,它在2181上,当开始Kafka时,它看着2181“zookeeper”然后在我身上爆炸。忠告?
我一直在使用spotify提供的Kafka图像在本地运行Kafka。我目前正在尝试将它与和图像一起使用。 我需要帮助解决这个问题: 错误(日志组:)
错误: 正在启动客户端连接,connectstring=localhost:2181 sessiontimeout=60000 watcher=org.apache.curator.connectionstate@7bf272d3[info]o.a.z.clientcnxn-打开到服务器localhost/127.0.0.1:2181的套接字连接。将不尝试使用SASL(未知错误)[info]K.M
我必须在ConsumerGroup中设置zookeeper IP地址,而不是Kafka-Host IP地址。因为我将复制因子设置为3,并且创建了3个代理。因此,如果一个主机出现故障,那么另一个主机可以接管。 当我尝试将zookeeper的IP地址而不是Kafka-Host的IP地址放在ConsumerGroup中时,它不会接收到任何来自生产者API的消息。 我希望这样,如果我在ConsumerGr
从Storm0.9.1升级到0.9.2后,我在尝试运行灵气时出现了以下异常: 杀死QuorumPeerMain灵气后能够运行。看起来动物园管理员出了问题,或者旧zk版本的一些痕迹仍然缓存在某个地方。 是什么导致了这个问题?