有没有用于生成流数据的模拟器/工具？
为了测试目的，我需要模拟客户端每秒生成100,000条消息并将它们发送到kafka主题。是否有任何工具或方法可以帮助我生成这些随机消息？
在类线程之间发送消息的Python方法
在不使用全局变量的情况下，有没有人知道我如何在这段代码中从threadOne发送变量（或获取变量）到threadTwo？如果不行，我该如何操作全局变量？只需在两个类之前定义它并在run函数中使用全局定义即可。 import threading print "Press Escape to ...
RabbitMQ：如何指定要发布到的队列？
RabbitMQ的Channel＃basicConsume方法提供以下参数：channel.basicConsume(queueName, autoAck, consumerTag, noLocal, exclusive, arguments, callback); 让我们具有告诉Ra...
普通队列 vs SEDA队列
作为Apache Camel的新手，我最近正在审查其长列表中的组件，并偶然发现它们支持SEDA队列组件。 这个页面对我来说毫无意义，所以我搜索了一下“SEDA队列”这个词，并找到了维基百科文章here。 阅读完那篇文章后，我无法区分SEDA队列和普通的“普通”队列之间的区别！两者都通过使用...
Django中的私信功能
我正在寻找一个现成的Django应用程序，提供用户之间的私人消息功能。我看到了django-pm和django-messages，但它们似乎都没有在特别积极地开发。难道真的没有其他选择吗？
如何从AMQP(RabbitMQ)队列中有选择地删除消息？
我希望能够选择性地从AMQP队列中删除消息，而不必读取它们。 场景如下： 发送方想基于X类型的新信息到达这一事实过期X类型的消息。因为订阅者很可能还没有消费最新的X类型消息，所以发布者应该只删除之前的X类型消息，然后将最新的消息放入队列中。整个操作对订阅者应该是透明的 - 实际上，他应该使...
Kafka生产者能否创建主题和分区？
目前我正在评估不同的消息系统。 有一个关于Apache Kafka的问题，我自己无法回答。 一个Kafka生产者是否能够动态创建主题和分区（也可以在现有主题上创建）？ 如果是，这是否会带来任何不利影响？ 提前感谢您。
处理RabbitMQ中的死信
TL;DR: 我需要将死信消息“重放”到它们原始的队列中，一旦我修复了最初导致消息被拒绝的消费者代码。我已经为RabbitMQ配置了Dead Letter Exchange（DLX），并成功地将被拒绝的消息路由到死信队列。但现在我想查看死信队列中的消息，并尝试决定如何处理每个消息。其中一些（很...
Protocol Buffers的替代方案
我需要一个基本的消息传递/远程过程调用（RPC）系统。我可以使用序列化系统，但我希望有一些验证来确保双方同步。我已经看过Google Protocol Buffers，但我不太喜欢代码生成。还有其他替代方案吗？
如何将Android应用程序作为Kafka客户端使用？
有没有可能或者说有没有意义使用安卓应用作为Apache Kafka的"生产客户端"? 比如，我的安卓应用需要捕获和分析反应时间数据。目标是收集所有数据并实时在应用中显示平均反应时间。 另一种选择是拥有一个应用服务器作为中介，接受来自安卓应用的消息并将它们发布到Kafka，而不是让应用成为K...