我对卡夫卡很陌生。我有以下架构：我很困惑
1) whether I can run kafka producer, broker and consumer
浏览 6提问于2015-11-02得票数 0
回答已采纳
3回答
我有一个应用生产者-消费者设计模式的应用程序。它是用java编写的。简而言之，生产者将项目放在阻塞队列中，消费者从那里取出项目。消费者应该一直运行，直到生产者发出停止的信号。将这个信号从生产者传递给消费者的最好的方式是什么？首席设计师说他希望保持生产者和消费者的分离，但除了在消费者线程池上调用一个方法之外，我没有看到其他任何方法。
浏览 4提问于2013-05-13得票数 1
回答已采纳
6回答
我正在看一个关于Java多线程的视频教程。介绍了用Java实现著名的“生产者-消费者”问题。
它使用wait()和notifyAll()来确保生产者线程和消费者线程之间的正确通信。这位导师故意创建了几个生产者线程，而只有一个消费者线程，但他留下了一个未回答的问题：“最好是生产者线程和消费者线程的数量相等，如果生产者线程比消费者线程多，就会有问题”。
浏览 2提问于2013-04-05得票数 5
回答已采纳
1回答
带有条件变量的Java互斥关联
、、、、
Java中的每个条件变量(wait()、notify())都与单个互斥(同步)相关联。我曾说过(在Java中)，每个互斥对象也与一个条件变量相关联，这是一个比p线程的cond变量和互斥变量更低效率的实现。然而，我无法理解这一条。那是什么意思？Java与C/C++线程在这个问题上有什么不同？
浏览 3提问于2016-01-31得票数 2
回答已采纳
3回答
我有两个线程，一个是生产者，另一个是消费者。都在不同的类中。这两个线程独立运行。生产者汇集了大约8-12个文件夹用于输入。一旦生产者线程完成，消费者线程现在进入'readyToLoad‘文件夹，并开始处理翻译后的文档。现在的问题是，当消费者正在处理翻译的文档时，它不允许生产者在'readyToLoad‘文件夹中放入更多的翻译文件。
我的问题是，我如何防止消费者锁定'readyToLoad‘文件夹？更新:添加了消费<
浏览 0提问于2013-07-19得票数 1
我正在设计一个系统，其中将有n生产者和m消费者，其中n和m是数字，n != m。
在java中，如果我使用同步关键字，那么它将阻塞相应的调用方。
浏览 5提问于2015-04-30得票数 4
1回答
在soap中，生产者使用WSDL将消息的结构传递给消费者。
最近学到了基于REST的web服务，从消费者/生产者的角度来看，我确实发现在使用方面有很大的不同(是的，内部是完全不同的)。我的问题是生产者如何将消息的结构传递给消费者，因为这里有WSDL类型的东西。我相信WADL是存在的，但到目前为止还不是标准的？生产者在这里是以java类(如果是基于java的消费者)还是基于.net的类(如果是基于.net的<
浏览 2提问于2017-01-27得票数 1
1回答
我正在通过Java代码中的许多对象实例传递生产者或消费者引用。在其中一些，我想做一些检查卡夫卡的配置。这意味着我想要回到，什么是有效的配置存储在卡夫卡生产者/消费者(包括默认)。在java文档中，我没有看到任何明确的内容：
那么，如何将带回卡夫卡的生产者和消费者配置呢？
浏览 8提问于2017-12-06得票数 8
回答已采纳
2回答
在ActiveMQ (Java版)中，我似乎找不到一种方法来侦听新的生产者和消费者连接(或连接中断)。我希望能够告诉消费者(或者他们可以自己发现)，生产者的连接中断了。反过来(生产者发现某个消费者断开连接)也是必需的。
如果能帮上忙我会很感激。
浏览 0提问于2009-11-10得票数 4
回答已采纳
1回答
我想知道是否有可能通过AMQP和RabbitMQ为生产者和消费者使用不同的语言？
例如:生产者使用Java，消费者使用python/php，反之亦然？
浏览 0提问于2012-08-12得票数 3
回答已采纳
我用Java的编写了一个基于生产者/消费者的程序。如果所有的生产商都完成了，我正试图找到一种阻止消费者的方法。有多个生产者，但只有一个消费者。我为“一个生产者，许多消费者”的场景找到了几种解决方案，例如使用“做好的帕克/毒药药丸”(参见)，但我的方案正好相反。
有什么最佳实践解决方案吗？
浏览 2提问于2013-11-16得票数 1
回答已采纳
2回答
Kafka Rest示例
、、、
有没有使用Java中的Kafka rest api的生产者和消费者组的好例子。我不是在寻找生产者和消费者的简单消费者或卡夫卡客户端的例子。任何帮助都会被接受。
浏览 2提问于2016-08-17得票数 3
回答已采纳
2回答
使用ZMQ的均匀分布
、、、
我的任务是使用ZMQ编写一个java程序，它将有一个生产者和多个消费者。如果生产者发送100条消息，并且有4个消费者，则所有消费者必须每个消费者共享25条消息。我该怎么做呢。
浏览 0提问于2012-07-11得票数 0
回答已采纳
我正在开发一个使用Java开发的基于多线程的Web应用程序。
我在该应用程序中有两个线程，类似于生产者和消费者，其中一个线程不断地从第三方API (套接字连接)读取数据，并将其更新到缓存中。
浏览 2提问于2012-09-17得票数 0
回答已采纳
我创建了生产者和消费者，生产者将消息发布到一个主题中，消费者从topic.My中获取这些消息，问题是生产者如何发布更多的主题或分区，消费者如何获取它们？建议如何发布多个主题以及创建主题分区的方法。我浏览了很多网站，但是没有得到任何合适的java代码来做这些事情。
致以问候。
浏览 2提问于2018-04-17得票数 0
问题：生产者的生产速度高于消费者。现在，在停止生产者时，消费者仍然继续使用队列中的数据。
浏览 2提问于2014-06-10得票数 2
回答已采纳
1回答
我对生产者消费者食谱将如何与Zookeeper合作几乎没有疑问。拥有不同的生产者和消费者实例意味着没有任何本地锁(同音化)会有任何用处。
浏览 4提问于2013-05-12得票数 0
回答已采纳
在我使用队列在生产者线程和消费者线程之间进行通信的情况下，人们通常会推荐使用LinkedBlockingQueue或ConcurrentLinkedQueue
使用一种比另一种有什么优点/缺点？
浏览 2提问于2009-09-15得票数 120
回答已采纳
1回答
我正在尝试写一个生产者消费者代码。下面是我编写的原始代码。编辑
根据建议，我尝试更改代码，以便有两个独立的对象供生产者和使用者锁定。此外，当一个对象被放入缓冲区时，生产者会通知消费者。
浏览 1提问于2018-12-21得票数 0
我想在Java生产者和Java消费者之间建立一个安全的web服务。我想使用Active Directory进行身份验证，身份验证使用的是生产者和消费者运行时所使用的域帐户。
你能给我举个例子吗？
浏览 0提问于2008-11-28得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
