当前位置: 首页 > 知识库问答 >
问题:

多代理集群

华献
2023-03-14

本教程用于多代理kafka集群。我建立了三个经纪人:

  • 本地主机:9092
  • 本地主机:9093
  • 本地主机:9094

问题是,如果我杀死9092,我就不能使用以下命令:bin/kafka-console-consumer.sh--bootstrap-server localhost:9092--from-beginent-topic my-replicated-topic

我知道端口被杀死了,但是--如何通过通用引导服务器来使它运行?我错过了什么?

编辑1:

bin/kafka-console-consumer.sh--bootstrap-server localhost:9092,localhost:9093,localhost:9094--from-beginent-topic my-replicated-topic

它给了我一个信息:

警告[Consumer ClientID=Consumer-1,GroupID=Console-Consumer-82352]无法建立到节点-1的连接。代理可能不可用。(org.apache.kafka.clients.NetworkClient)`

和控制台停止。未读取消息

共有1个答案

连翰
2023-03-14

您可以在bootstrap-server中使用代理列表:

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092,localhost:9093,localhost:9094 --from-beginning --topic my-replicated-topic
 类似资料:
  • 从服务器1的web控制台创建的消息在服务器2的web控制台中不可见。这种配置有什么问题? web控制台中的状态:

  • 我在应用程序中使用了JavaFX网络视图。在其中,我加载了一个本地html文件,该文件本身从地图加载了一些javascript库。谷歌。com,然后在网络视图中显示带有一些标记的谷歌地图。 现在根据这个问题,如果我想使用代理,我应该做: 但这没有效果。我可以将我想要的任何东西设置为主机和端口。即使设置没有有效的代理,谷歌地图磁贴仍然被加载。所以很明显它没有使用代理设置。 如何确保WebView中的

  • 在Ubuntu上使用Kafka:Zookeeper启动Kafka启动主题创建生产者启动消费者启动消息在生产者和消费者之间传递良好 我创建了2个新的server.properties文件:server-1.properties: 服务器-2。属性为: 当我开始新经纪人时: 错误为:

  • 几乎所有 HTTP 客户端都支持通过中间代理进行调用。传统上,这被用于在与外部世界的连接受到限制的防火墙环境中运行。然而,由于 linkerdd 可以作为 HTTP 代理,并且由于使用代理通常可以在没有代码更改的情况下实现,所以这种方法为使用 HTTP 的应用程序提供了一个简单的集成路径。 用linkerd作HTTP代理 linkerd 可以作为 HTTP 代理工作,无需任何额外的配置,提供关键功

  • execute方法不仅可以执行单条查询语句,而且还可以执行多条查询语句,不同查询语句之间用分号(;)隔开。在给出例子之前,先使用如下SQL建立一个图书销售表t_booksale,并向其中插入三条记录。 建立t_booksale表 DROP TABLE IF EXISTS mydb.t_booksale; CREATE TABLE mydb.t_booksale ( id int(10)

  • 我有一个带有两个代理的Kafka集群,每个代理都在自己的(AWS)服务器上(我使用这里的intstructions设置集群)。我正在使用SASL(但没有加密)。在运行Broker2的服务器2上,我创建了一个主题: 看起来是成功的,因为描述主题表明它至少是被创造出来的: 正如您所看到的,该主题没有被指定为领导者,也没有同步副本。我已将写入权限分配给制作者: 但是,我的制作人不能写这个题目: 有人能建