我已经开始实施卡夫卡制作人和发布信息的主题，从那里到卡夫卡消费者收到的json。
现在，我需要发送json有效负载从卡夫卡消费者到谷歌酒吧/潜艇。我很困惑，我应该为此需要卡夫卡的消费者吗。或者只是从卡夫卡生产者到谷歌酒吧子，我可以发送通过使用卡夫卡connector.jar和配置在主题中的属性。对于此实现，任何帮助都是非常感谢的。
浏览 3提问于2019-03-21得票数 1
回答已采纳
如果使用者对来自主题(offset = OFFSET_END)的消息是最新的，那么消费者如何执行它的阻塞poll()如果这有关系的话，我正在使用汇合python客户端。
谢谢!
浏览 4提问于2019-10-24得票数 1
回答已采纳
卡夫卡是一个公共子系统，但消费者从卡夫卡经纪人那里提取数据--我已经读过，拉比推(有一些缺点)更好，但是如果我们要提取数据，为什么我们称它为酒吧子系统呢？在这里，Kafka并不是在通知已经订阅的用户，而是消费者正在显式地提取数据。(有一些资源称其为pub-sub，因为在使用者读取数据(发生在队列中)之后，数据不会被删除。然而，酒吧的名字仍然让我感到困惑)。
如果消费者正在从代理中提取数据，那么我理解消费者需要将其提交给代理(传递语义)，但是为什么我们在Kafka中说，我们可以从我们想
浏览 2提问于2022-08-09得票数 0
1回答
我正在运行ubuntu 16.10，并希望通过我的蒸汽帐户发挥帝国的年龄2。每次我发布游戏时，我都会收到一条信息，上面写着“帝国的时代2: HD版本在你当前的平台上是不可否认的”。有什么解决办法吗？
浏览 0提问于2016-11-03得票数 0
1回答
消费者-生产者模式
、、、
什么是最好的方式来实现一个基于多进程的消费生产者模式，并将pyarrow作为熊猫数据的快速存储库？
目前，我正在使用redis酒吧潜艇，但我认为可能有一个更有效(更快)的解决方案？你能举个例子吗？
浏览 0提问于2018-07-22得票数 1
回答已采纳
1回答
我试图理解卡夫卡的消费群体概念。所以我的问题是--消费者群体和话题之间的关系是什么？属于同一消费群体的两个不同的消费者可以从不同的主题中阅读吗？
浏览 4提问于2016-09-22得票数 3
回答已采纳
auto-formatting nicer for build methods. }AndroidStudio的控制台显示：
Syncing files to device Linux
浏览 8提问于2021-12-24得票数 0
回答已采纳
我有一个直接频道：public DirectChannel emailingChannel() { .direct( "emailingChannel")}@Bean return IntegrationFlows.from( "emailingChannel" )
浏览 1提问于2019-02-27得票数 0
回答已采纳
我创建了一个函数应用程序，详细信息如下： publish: codeversion: 3.7OS: Linux
Plan Type:我得到以下错误 Editing functions in the Azure portal is not supported for Linux Consumption Function Apps.
浏览 73提问于2020-06-21得票数 3
回答已采纳
我的想法是输入您想要的时区的CRON时间，然后通过Azure门户将配置选项WEBSITE_TIME_ZONE设置为America/New_York (参见显示Azure函数运行的是Linux而不是America
浏览 12提问于2022-07-16得票数 1
回答已采纳
运行在Linux 上的Azure函数消费计划。基本上，我想要，但是在Linux上。
浏览 0提问于2019-08-29得票数 4
回答已采纳
1回答
我正在开发的带有JMS1.1 (TibcoJms 4.4.1)的遗留系统在服务器端建立了一个JMS队列(而不是主题)，用于PTP通信模式。服务器将不断将消息项放到队列中。我想我可以这样做的一种方法是在队列上实现一个监听MessageListener，该队列充当一个“开关”，将接收到的消息分发(推送)到客户端的每个线程以进行处理。或者，我可以在服务器上实现一个侦听该队列的MessageListener，并将接收到的消息放在客户机上的一个新队列上，每个线程将对客户端队列进行轮询。
不管怎样，我认为我需要在线
浏览 4提问于2014-09-18得票数 1
回答已采纳
我正在执行Azure函数的消费计划，并试图遵循这个堆栈溢出答案中的指南：
使用：查找SCM页面，但此页面不可用。还有其他方法来打开Kudu控制台，它适用于Azure函数的消费计划吗？
浏览 4提问于2019-05-08得票数 1
回答已采纳
我很可能会使用Google / sub作为酒吧子引擎，但我想如果我切换到Kafka，我也会有同样的问题。我有几个问题：
我应该把其他东西完全用作消费者吗？
浏览 3提问于2017-05-03得票数 2
在20世纪90年代末和2000年初，我尝试了“活跃的世界”等等。他们让我注册一个账号，然后在一个巨大的3D世界里四处走动，和人/化身聊天。这是超现实的，坦率地说，感觉比刺激更可怕和不安，尽管有明亮和多彩的视觉效果。现在，这个"Metaverse“又一次被不断地提到/推倒。这一次，我甚至没有下载任何东西(我打赌我现在甚至都不能加入它，因为它似乎需要一个Facebook帐户或什么)，而只是看了YouTube上的游戏录像。
看起来就像几年前22+做的那样。不是开
浏览 0提问于2022-01-20得票数 0
我们有一个Redis服务器，所有客户端都可以连接到它来执行各种数据传输和协调任务。我们有一个新的要求，我们支持视频流。我想避免运行一个专用服务(附带的所有网络和安全需求)，而只是在Redis上进行流。
我不知道
浏览 4提问于2022-04-06得票数 5
在我们的Linux系统上，我们使用命名管道进行进程间通信(生产者和消费者)。
为了测试消费者(Java)代码，我想(用Java)实现一个虚拟生产者，它向连接到消费者的命名管道写入数据。在Linux中我可以使用mkfifo (称为使用Runtime.exec() )，但在Windows上该如何操作呢？
浏览 2提问于2009-03-11得票数 28
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
