问题标签 [broker]

我正在使用卡夫卡2.9.2-0.8.1版本..

从文档来看，这似乎load balancing是为配置的集群自动完成的。

这是我的 Java 生产者配置：

注意：我保留了 Kafka 发行版提供的所有默认配置。

Zookeeper 似乎发现了我的另一个经纪人：10.10.70.15.. 当我检查日志时..

我test-topic在其中一个经纪人上创建了一个.. 使用console-producer.sh.. 然后在所有其他注册的文件夹中创建了适当directory的文件夹。/tmp/kafka-logsbrokerszookeeper

-->./kafka-topics.sh --create --zookeeper 10.10.73.52:2181 --replication-factor 2 --partitions 2 --topic test-topic

我已使用以下提供的行来订阅两台代理机器上的主题..

-->./kafka-console-consumer.sh --zookeeper 10.10.73.52:2181 --topic test-topic

生产者代码：

我看到both the brokers收到相同的数据..负载不平衡。

我是否需要实现任何其他负载平衡/分区逻辑？

任何想法我在这里想念什么？

我正在尝试使用芹菜处理一些任务，但我运气不太好。我正在运行 celeryd 和 celerybeat 作为守护进程。我有一个tasks.py看起来像这样的文件，其中定义了一个简单的应用程序和任务：

process.py这个文件是从我用来监视文件更改的另一个文件中引用的，如下所示：

有了这个小代码，celery 就无法看到任务并处理它们。我可以在 python 解释器中执行类似的代码并 celery 处理它们：

然而，当我从解释器运行任务时，beat.log并worker1.log没有显示任何指示任务已收到，但使用logging我可以确认任务代码已执行。文件中也没有明显的错误.log。任何想法可能导致此问题？

我的/etc/default/celerybeat样子：

并且/etc/default/celeryd：

嗨，我正在评估 ActiveMQ 中的不同发现协议，但代理网络中的多播发现存在问题。

我已经设置了一个代理网络，其中 3 个 activeMQ 代理连接到一个多播组

<transportConnectors> <transportConnector name="default" uri="tcp://192.168.11.1:61616" discoveryUri="multicast://default?group=Bus"/> </transportConnectors>

我在不同的网络中有一个生产者 - 192.168.5.10，当我尝试创建与网络的连接时，我的生产者无法发现它

但是当我尝试使用故障转移进行连接时，我能够成功创建连接并生成消息

现在我的问题是如何使多播 uri 可以在全球范围内访问？我在这里提到了以下文档。但不足以让我理解。

如果有人可以对此有所了解，那将非常有帮助。提前致谢！

在 Kafka 中，我只想使用一个代理、单个主题和一个分区，该分区具有一个生产者和多个消费者（每个消费者从代理获取自己的数据副本）。鉴于此，我不希望使用 Zookeeper 的开销；我不能只使用经纪人吗？为什么必须要有动物园管理员？

有人可以用简单的英语向我解释经纪人模式吗？可能就 Java 或现实生活中的类比而言。

对于一个项目，我想将项目从简单代理切换到全功能代理（如 rabiitmq、apollo）。

异常堆栈：

这是配置代码：

发送消息代码：

这是触发实体：

请帮帮我！谢谢！

我正在尝试将 Celery 与 Redis 一起使用。

这是我的celery.py文件：

这是我的celeryconfig.py文件：

当我运行时：

我收到了这个错误：

最后是我的项目结构：

我在用：

• 芹菜 3.1.11
• Redis 2.8.8

我需要以自定义方式处理来自客户端的 ACK 命令。整合逻辑的最佳方法是什么？我的网络套接字配置：

我正在使用 ZeroMQ 开发分布式应用程序。我想实现一个代理在集中式主机中传递消息。

想象一下服务器客户端向给定服务器请求某些东西。ZeroMQ 指南中的示例，几个客户端向服务器请求某些内容，一些不忙的工作人员完成工作并回复请求。

我需要指示请求。我的意思是，我想要那台服务器 5（例如）来完成这项工作。这使用中间的代理将通信集中在单个主机中。

任何想法？

编辑

我画了一张图：https ://docs.google.com/drawings/d/1kyh6agIG_3FsllPURSjJFTHGjv-Yg92mfOiTmCdEsO8/edit?usp=sharing

我的案例 2 和指南中的负载平衡代理示例之间的区别（我认为）是代理将请求分配给第一个空闲工作人员。我需要向特定服务器发出请求。我希望现在很清楚。

编辑2

更清楚。我需要这个确切的例子。但我看不到客户端如何向特定服务器请求。我运行该示例，但所有请求都由第一个非繁忙服务器回复。

我对 Spring MVC 和 Web 技术很陌生。

我需要在我的 Web 应用程序的服务器端和客户端之间进行“实时”交互。当用户单击按钮时，我想执行服务器端代码，创建一条消息并将其发送给每个客户端。

我认为 Web Sockets 是解决方案。我可以在我的应用程序的控制器部分添加方法。当用户单击按钮时，将调用 Controller 方法。我可以执行代码并为每个客户发回一条消息。

但是现在，我可以接收来自另一个网站的消息。假设我正在使用 MessageListener。

我应该如何通知我的客户？WebSockets 的服务器端在控制器中。我认为我不应该从服务器调用此方法。

我可以创建某种奇怪的适配器 - 与服务器建立 WebSocket 通道（本地通道） - 使用代理从另一个网站接收消息 - 将消息发送到控制器

我不觉得这是一个不寻常的需求，我的解决方案看起来很棘手。我相信有一种更简单的方法可以做到这一点，但我找不到它。

那么，我做对了吗？你有什么想法，有什么建议吗？

谢谢您的帮助。

本