腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
3
回答
Apache
Kafka
消息
广播
、
我正在研究Apache-
kafka
,有一些困惑。请帮助我理解以下场景。所以我的问题是:这10个消费者如何与主题分区p1交互。
浏览 0
提问于2018-08-06
得票数 0
4
回答
Kafka
:生产者如何才能只发送给某个Consumer/GroupId
自从我开始使用
Kafka
以来,我注意到
Kafka
正在
广播
每个消费者或群体的
消息
。如何让生产者只将
消息
发送给某个特定的消费者?我说的是一个主题系统谢谢
浏览 1
提问于2018-01-04
得票数 0
1
回答
如何在Lagom中将
消息
发布到
Kafka
主题
、
、
尝试一个微服务,其中我接收一条
kafka
消息
,并在一些处理之后发布另一条
消息
到不同的
kafka
主题。基于这个link,我的理解是,应该在构造的主题上发布一条
消息
-特别是我提到的示例代码的这一部分。KafkaEvent.class, id)); System.out.println("Sent to:" + topic.toString()); 我没有在
kafka
浏览 5
提问于2019-09-16
得票数 0
3
回答
发送给具有相同使用者组名称的所有使用者的
消息
消费者代码如下:from
kafka
.consumer import SimpleConsumer print message 然后我用脚本生成
消息
: bin/
kafka
-console-producer.sh --broker-listlocalhost:9092 --topic my-
浏览 0
提问于2014-02-16
得票数 2
回答已采纳
1
回答
如何在服务器实例之间共享HTTP2 2/gRPC流?
、
、
、
make(chan error),}
广播
消息
是通过循环连接并使用stream.Send推送
消息
来完成的。
浏览 4
提问于2022-11-17
得票数 0
1
回答
发布订阅模式下
Kafka
消息
处理规模如何?
所有的人,请原谅我,我是一个新手刚刚开始的
Kafka
。目前,我正在阅读
Kafka
关于的文档。对于传统的信息系统。它们不能缩放
消息
处理。因为 但是对于
Kafka
来说。文档说,即使在发布-订阅模式下,
Kafka
也可以扩展
消息
处理。(如果我错了,请纠正我。谢谢。) 卡夫卡的消费群体概念概括了这两个概念。与发布订阅
浏览 1
提问于2017-07-16
得票数 0
1
回答
在Flink数据流中进行元数据连接的最佳方式是什么?
、
我们有一个
kafka
事件流,我们希望使用驻留在MySQL DB中的一些元数据来丰富它。有没有更好的办法?
浏览 0
提问于2021-04-02
得票数 0
2
回答
向同一消费者组内的所有订户
广播
消息
使用apache-
Kafka
版本2.11-2.4.0。 我正在创建一个应用程序,我想在其中向同一消费者组中的所有订阅者(消费者)发布事件。但在许多地方,我发现
Kafka
向消费者群体
广播
消息
。
浏览 23
提问于2020-01-09
得票数 1
回答已采纳
2
回答
从
kafka
发送
消息
到websocket
、
、
在这个项目中,我还使用了一些来自特定主题的
kafka
消息
。我想要实现的是把我从主题中接收到的信息倾注到websocket中。因此,通信只是一种方式,超过一个人可以连接到网络套接字,并看到
消息
进来。我想要使用通道,所以在接收
kafka
消息
的函数中,我有如下所示:在gin框架中,我创建了如下所示: </body> &l
浏览 11
提问于2022-03-22
得票数 0
回答已采纳
1
回答
Kafka
-发布给组中的所有消费者
、
、
所以,简而言之,我想让我在同一组中的所有服务接收那里的所有
消息
。(一次/
消息
) 我如何使用
Kafka
实现这一点? 谢谢你对我的照顾。
浏览 25
提问于2020-04-13
得票数 0
回答已采纳
1
回答
如何将alpakka
kafka
与akka流websocket相结合
、
、
、
、
我使用使用
kafka
的数据,如下所示:implicit val materializer: Materializer = ActorMaterializer() val config = system.settings.config.getConfig("akka.
kafka
.consumerRuntimeException(s"Connection failed: ${upgrade.res
浏览 0
提问于2019-04-11
得票数 1
回答已采纳
1
回答
为什么spring-cloud-config示例测试需要旋转配置服务器?
、
、
、
、
我还使用了Spring Cloud Stream
Kafka
和Spring Cloud Bus,同时启用了Spring Security基本身份验证。
浏览 7
提问于2018-07-09
得票数 0
1
回答
使用两个独立的应用程序(storm和spark streaming)消费
Kafka
消息
、
、
我们使用Storm开发了一个摄取应用程序,它使用
Kafka
消息
(一些时间序列传感器数据)并将这些
消息
保存到Cassandra中。我们使用Nifi工作流程来实现这一点。我现在要开发一个单独的星火流应用程序,它需要消费这些
Kafka
消息
作为源。我想知道为什么当两个应用程序与一个
Kafka
Chanel交互时会出现问题?我是否应该将Nifi中的
Kafka
消息
复制到另一个Chanel,以便我的Spark Streaming应用程序使用它们,但这是一个开销。
浏览 0
提问于2017-04-30
得票数 0
2
回答
JMS与特定条件下的
Kafka
、
Kafka
保证有序投递和多订阅者。卡夫卡是怎么做到的?Q1:在这种情况下,哪个更好?请给我提个建议。
浏览 1
提问于2017-03-08
得票数 18
回答已采纳
4
回答
Kafka
使用者为主题获取元数据失败
、
我试图为第三方的
Kafka
和ZooKeeper服务器编写一个Java客户机。我能够列出和描述主题,但当我尝试阅读任何主题时,都会引发ClosedChannelException。:73) at
kafka
.producer.SyncProducer.send(SyncProducer.scala:113)
浏览 4
提问于2015-06-02
得票数 39
回答已采纳
2
回答
Flink运算符中的内存查找
该应用程序由
Kafka
作为事件源、协同映射函数和
Kafka
接收器组成,如下图所示:我想用CSV文件中的一些字段丰富
Kafka
输入的流。我还希望定期刷新配置磁盘位置的csv文件。潜在的解决方案:
广播
丰富的数据,并连接来自卡夫卡的事件流,基于某种逻辑。 是否有更好的设计来使用CSV文件实现内存中的查找?
浏览 1
提问于2022-02-19
得票数 0
2
回答
KafkaUtils010 SparkStreaming中的MessageHandler
、
、
、
我想按主题分组,或者在申请时知道
消息
来自哪个主题: ssc, Array(topicConfig.srcTopic), )然而,在最新的API中,
kafka
0
浏览 16
提问于2017-03-15
得票数 0
回答已采纳
1
回答
在hyperledger fabric中如何在对等通道中传递两个排序者的创建?
、
我正在探索基于
Kafka
排序的Hyperledger fabric,当我尝试使用CLI创建通道时,我需要传递排序程序。 我现在已经使用
Kafka
创建了两个订单器,但是如何在创建通道时传递两个订单器。
浏览 0
提问于2019-03-02
得票数 0
1
回答
改进Flink
广播
性能
、
我有一条在事件流上应用转换规则(来自
广播
状态)的管道;当我并行运行
广播
流和原始流时,流性能确实很好,但是当我执行
广播
转换性能时,会急剧下降。我怎样才能获得更好的表现。我附上了这两种场景的快照: 顶层行显示来自
Kafka
的流消费事件,底部行显示从另一个主题中消耗的规则。I已将
广播
流与数据流连接起来,以便将来进行处理。请注意,仅为了测量
广播
的性能,我确保数据流(顶部行)中没有使用任何记录。在
广播
状态的处理端,我只将接收到的
消息
存储到MapState。
浏览 7
提问于2020-09-10
得票数 0
回答已采纳
1
回答
Flink维护配置状态
、
、
我有一个在Flink中维护配置的用例,我真的不知道如何处理。 假设我在某个地方存储了一些配置,我需要它来执行我的处理。在初始化Flink作业时,我希望加载所有配置。 此配置也可以在运行Flink作业期间修改,因此我必须在内存中保留此配置的状态,并在需要时对其进行更新。可以从KafkaSource访问配置的更新。 所以这就是我所拥有的: 我有一个函数可以加载整个配置,使其处于一种状态,并将其与我的数据流相关联: public class MyConfiguration extends RichFlatMapFunction<Row, Row>{ private transi
浏览 14
提问于2019-10-09
得票数 1
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
消息队列之 Kafka
Kafka是批量发送消息的?
IoT平台消息广播Broadcast实战
Kafka分布式消息系统剖析
kafka 内部是怎么存储消息的
热门
标签
更多标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
活动推荐
运营活动
广告
关闭
领券