Zookeeper是否是Kafka必需的？
在Kafka中，我想只使用单个代理、单个主题和一个分区，其中有一个生产者和多个消费者（每个消费者从代理获取自己的数据副本）。鉴于此，我不想使用Zookeeper的开销；我能不能只使用代理？为什么必须使用Zookeeper？
如何解决“警告：React在DOM元素上未识别X属性”的问题？
我正在使用一个叫做 react-firebase-js 的东西来处理Firebase授权，但是我的React和提供者-消费者思想的理解有限。 起初，我在顶层构建了一个非常大的JSX组件，它能正常工作而没有警告。但是当我尝试将其拆分成组件时，我得到了标题中显示的警告和其他几个警告。 这样做没有警...
阻塞队列和多线程消费者，如何知道何时停止
我有一个单线程的生产者，创建一些任务对象并将它们添加到 ArrayBlockingQueue 中（大小是固定的）。 我还启动了一个多线程消费者。这是构建为固定数量线程池 (Executors.newFixedThreadPool(threadCount);)。然后，我向该线程池提交一些 Co...
使用队列的生产者/消费者线程
我想创建一种类似于生产者/消费者的线程应用程序，但我不确定在它们之间实现队列的最佳方法是什么。 所以我想到了两个想法（可能都是错误的）。我想知道哪一个更好，如果它们都不好，那么最佳的队列实现方法是什么。这些示例中，我主要关心队列的实现方式。我正在扩展一种队列类，它是内部类并且是线程安全的。下...
如何在Python中迭代Queue.Queue项目？
有没有一种Pythonic的方法可以迭代一个Queue.Queue的元素 而不是 将它们从队列中移除。 我有一个生产者/消费者类型的程序，其中要处理的项通过使用Queue.Queue传递，我想能够打印剩余的项是什么。 有什么想法吗？
作业队列作为具有多个消费者的SQL表（PostgreSQL）
我有一个典型的生产者-消费者问题：多个生产者应用程序将作业请求写入PostgreSQL数据库上的作业表。作业请求具有一个状态字段，在创建时包含QUEUED。存在多个消费者应用程序，当生产者插入新记录时，它们会收到通知：CREATE OR REPLACE RULE "jobrecord...
Kafka中的消费者再平衡是如何工作的？
当添加或下线新的消费者/代理时，Kafka 会触发重新平衡操作。 Kafka 的重新平衡是阻塞操作吗？在重新平衡操作正在进行时，Kafka 消费者是否会被阻塞？
C#生产者/消费者
我最近接触了一个C#生产者/消费者模式的实现，它非常简单和优雅（至少对我来说是这样）。 这个实现似乎是在2006年左右设计的，所以我想知道这个实现是否： - 安全 - 仍然适用 以下是代码（原始代码参考自http://bytes.com/topic/net/answers/575276-p...
尝试在ConcurrentQueue中使用Dequeue方法。
在`ConcurrentQueue`中，如果队列中没有任何项，`TryDequeue`将返回false。 如果队列为空，我希望我的队列能够等待直到有新的项被添加到队列中，并且它会出队这个新项，然后继续这个过程。 在C# 4.0中，我应该使用`Monitor.Enter`、`Wait`、`P...
C++中的双缓冲单生产者单消费者数据结构
我在$work公司有一个应用程序，需要在两个实时线程之间移动，并且这两个线程的调度频率不同（实际调度不受我控制）。该应用程序类似于硬实时（其中一个线程必须驱动硬件接口），因此线程间的数据传输应尽可能无锁和无等待。 需要注意的是，只需要传输一个数据块：由于两个线程以不同的速率运行，较快的线程在...