腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
在
使用者
运行时
为
Confluent.Kafka
中
的
主题
使用
消息
.net-core
、
apache-kafka
、
message-queue
、
apache-zookeeper
我
在
.netCore项目中
使用
Confluent.Kafka
(1.4.4)作为
消息
代理。
在
项目启动时,我只将"bootstrapservers“设置
为
appSetting.json文件
中
的
特定服务器,并在必要时
使用
相关类
中
的
以下代码
在
API中生成
消息
: public async TaskconsumerBuilder.Close();
浏览 6
提问于2020-10-28
得票数 2
回答已采纳
1
回答
为什么我
的
ProducerBuilder类
在
.Net核心控制台中
的
消息
没有被.Net消费外壳所消耗?
c#
、
ubuntu
、
apache-kafka
、
publish-subscribe
、
kafka-producer-api
我
在
Ubuntu上安装了Kafka,并尝试
使用
shell文件测试一个简单
的
场景:bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic mytopicname: //
浏览 0
提问于2020-08-18
得票数 1
回答已采纳
2
回答
如何在
Confluent.Kafka
中
获得一个
主题
的
所有‘`PartitionTopic`s’
的
列表?
c#
、
apache-kafka
我正在
使用
confluent-kafka-dotnet (
Confluent.Kafka
)
为
Kafka生成
消息
。 我想手动管理
消息
转到哪些分区,以保持某些
消息
组
的
顺序。如何获取Kafka
主题
的
PartitionTopic列表? 我看过Java
中
的
this solution。但我不明白如何用
Confluent.Kafka
实现同样
的
功能。或者,可以
使用</em
浏览 113
提问于2020-07-14
得票数 2
回答已采纳
1
回答
C#无法
在
卡夫卡
主题
上消费信息?
c#
、
apache-kafka
、
confluent-platform
我一直
在
研究
Confluent.Kafka
客户端()
的
几个例子,虽然我可以成功地让一位制作人将一条
消息
推入卡夫卡,但我无法向消费者撤回任何
消息
。通过UI,我可以看到
主题
已经创建,
消息
正在进入这个
主题
(当前有10个分区和3个
消息
),但是我
的
使用者
总是报告“分区
的
结束”,而不消耗任何
消息
(这3条保留在
主题
上,"OnMessage“从不触发)
浏览 0
提问于2018-08-03
得票数 3
回答已采纳
1
回答
使用
来自
主题
的
最新
消息
并忽略所有先前发布
的
消息
apache-kafka
、
kafka-consumer-api
、
confluent-kafka-dotnet
假设我有一个
主题
"test“,它已经有了一堆
消息
,现在我想订阅这个
主题
。但我不想在新订阅之前
使用
所有发布
的
消息
。基本上,我只想消费订阅后发布
的
最新
消息
。
在
confluent.kafka
库中有什么特性可以帮助我实现这个特性吗? 提前谢谢。
浏览 12
提问于2021-06-03
得票数 0
1
回答
卡夫卡
主题
数量与分区数量
apache-kafka
我正在进行一个项目,在这个项目中,生产者可以在
运行时
(而不是固定数量)出现并发布
消息
。目前,他们发布到
在
卡夫卡代理
中
运行时
创建
的
唯一
主题
(topic.uuid),我
在
另一端有一个用户,它订阅了
主题
。*模式和订阅所有
主题
,并且随着新
主题
的
到来而重新平衡in.Is它是正确
的
方法吗?现在,我感到困惑
的
是,我们应该有一个具有多个分区
的
<
浏览 1
提问于2016-11-19
得票数 6
1
回答
兔子MQ虚拟
主题
?
rabbitmq
、
virtual-topic
在
兔子MQ
中
,是否存在与活动MQ虚拟
主题
相同
的
内容?或者任何其他机制都可以实现队列语义。一些
主题
订阅者需要在返回联机时传递持久
消息
,并进行负载平衡。编辑作为一个简单
的
例子,每当用户登录失败时,主应用程序就会发布一条
消息
。其中一个侦听器
为<
浏览 3
提问于2015-07-22
得票数 2
回答已采纳
1
回答
:如何为Kafka
主题
的
每个分区发送
消息
apache-kafka
、
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
我正在尝试实现一种机制来标记卡夫卡信息序列
的
结束。因此,我试图
在
每个
主题
分区
的
消息
序列末尾发送一条特殊
消息
(一种EOF)。如果
使用者
读取所有EOF
消息
,那么这意味着他已经完成了整个
消息
序列
的
处理。是否有办法
为
一个
主题
的
每个分区发送一个kafka
消息
? 编辑:
主题
名是在
运行时
发现
的
,因此分区<e
浏览 2
提问于2022-03-24
得票数 0
回答已采纳
2
回答
只有
在
某些条件
为
真的情况下,才能
使用
Kafka
的
消息
java
、
apache-kafka
、
spring-kafka
我们有特定
的
主题
,只有
在
条件consumeEnabled=true
的
情况下才需要
使用
消息
。所以,它应该是这样
的
: 如果应用程序正在启动并
使用
,则将分区分配给
使用者
并
使用
来自
主题
的
消息
。如果应用程序正在启动,则不要将分区分配给用户,也不要
使用
来自
主题
的
消息
。如果应用程序已经与consumeEna
浏览 1
提问于2019-12-16
得票数 1
回答已采纳
2
回答
如何在Kafka
中
对同一组ID
使用
不同编程语言中
的
多个
使用者
c#
、
node.js
、
apache-kafka
、
kafka-consumer-api
我想用Kafka (多种编程语言)
为
一个
主题
创建一个负载平衡。所以我做了下面的事。
在
NodeJs (消费者组:consumer2)
中
创建多一个
使用者
( testCo
浏览 2
提问于2019-12-13
得票数 0
1
回答
对kafka消费者
的
注释
c#
、
apache-kafka
、
annotations
、
kafka-consumer-api
、
confluent-platform
我想用C#收听卡夫卡
主题
的
消息
。 与Java中一样,有一个注解@KafkaListener,当它添加到函数之上时,侦听来自
主题
的
消息
,然后执行函数
的
逻辑。示例- @KafkaListener(topics = "topicname",groupId = "groupid") //函数代码在这里 同样,
在
使用
Confluent.Kafka
的
C
浏览 20
提问于2021-03-24
得票数 0
1
回答
多种
使用者
组不同
的
线程不像预期
的
那样工作
apache-kafka
、
kafka-consumer-api
所以我非常熟悉Kafka和消费者群体是如何运作
的
,因为不同消费群体
中
的
两个订阅相同
主题
的
消费者都应该得到自己发表
的
关于Kafka
主题
的
信息
的
副本。消费者预处理一切正常工作,两个
浏览 0
提问于2021-07-06
得票数 0
1
回答
未接收
消息
的
JMS
使用者
jms
、
activemq-artemis
我刚刚完成了一个关于JMS
的
教程,所以它对我来说是非常新
的
,我正在尝试理解基本知识。如果这件事重要的话,我正在
使用
ActiveMQ Artemis。我创建了两个简单
的
应用程序,一个名为Producer,另一个名为Consumer。我先运行Producer,然后运行Consumer。Consumer应用程序永远不会终止,也不会将
消息
打印到控制台。奇怪
的
是,如果我不手动终止Consumer并再次运行Producer,那么我就会看到Consumer应该在控制台上收到
的
浏览 5
提问于2021-12-30
得票数 0
回答已采纳
2
回答
如何处理Confluent Kafka
的
消费端
消息
处理故障?
c#
、
apache-kafka
、
confluent-platform
由于遗留系统
中
的
一些设计问题(悲观锁定),偶尔会有一些事务
在
消息
到达时失败,在这种情况下,我希望
消息
在
一段时间后返回。我正在试图弄清楚如何处理与Kafka
的
这种情况。我
的
源应用程序和目标应用程序都在.NET 4.6.1和c#
中
。我
使用
的
是
Confluent.Kafka
v0.9.5客户端库。Kafka
的
版本是0.10。
在
JMS世界
中</e
浏览 2
提问于2017-05-06
得票数 0
1
回答
有多线程卡夫卡消费者
的
每个分区,这是可能
的
,并建议,如果是的话,任何样本片段?
apache-kafka
、
kafka-consumer-api
我们正在
使用
Kafka 0.9版本,并且有大量
消息
被推送到kafka
主题
中
的
特定分区。
在
本
主题
中有多个这样
的
分区。我们
在
本
主题
中
为
每个分区分配了一个
使用者
,并且
在
主题
内部手动维护偏移量--外部数据存储
中
的
分区。我想知道,如果我们开始
在
一个
主题
分区
中
获得大量
的
浏览 2
提问于2016-01-20
得票数 3
1
回答
Active MQ VirtualTopic -
消息
保持排队,即使被分派到所有定义/链接
的
队列。
activemq
使用
Active MQ5.15.4并遵循
中
的
文档,当发送到VirtualTopic时,
消息
会被发送到所有连接
的
队列,但它们永远不会从发送
消息
的
虚拟
主题
中退出队列。 我们需要手动清除虚拟
主题
吗?将信息保留在
主题
中
的
原因是什么?它们可以稍后再发送吗?但是,当一个新队列链接到虚拟
主题
时,所有现有的排队
消息
都不会发送给它。还没有对此进行测试,但是连接队列
中</em
浏览 0
提问于2018-09-10
得票数 0
回答已采纳
1
回答
具有和不具有追溯模式
的
持久订阅之间
的
activemq差异
activemq
我刚刚开始
使用
activemq,我有一个关于追溯消费者
的
问题,为了启用这个功能,你需要有一个持久
的
订阅。但是,
在
主题
上启用追溯和不启用追溯
的
持久订阅有什么区别?activemq文件上说。追溯性
使用者
只是一个常规
的
主题
使用者
,它指出在订阅开始时,每次尝试都应该用来及时返回,并发送
使用者
可能遗漏
的
任何旧
消息
(或该
主题
发送
的
最后一条<
浏览 3
提问于2013-09-09
得票数 4
1
回答
使用
Apache.NMS读取来自C# (.net核心)
的
ActiveMQ虚拟
主题
中
的
“旧”
消息
.net-core
、
activemq
、
apache-nms
如何
使用
Apache.NMS阅读有关虚拟
主题
的
消息
?我尝试
在
主题
中添加"?consumer.retroactive=
浏览 8
提问于2020-05-05
得票数 0
1
回答
安慰:
在
未被标记为重发
的
情况下,将一条
消息
插入
c#
、
.net
、
solace
我想知道是否有一种方法可以
在
不让邮件被标记为
在
“慰藉”中被重新传递
的
情况下破解一条
消息
。 情况:有一个由多个订阅者服务
的
保证队列,我们希望另一个订阅服务器处理特定
的
消息
。这是个非常棘手
的
案子。
浏览 4
提问于2015-12-04
得票数 1
回答已采纳
1
回答
用于时间序列数据持久性
的
Apache
apache-kafka
如何构造这些信息并将其表示
为
Apache
中
的
一个
主题
。我不确定我可以创建
的
主题
的
数量是否有限制。 如果我
为
这个分区
主题
编写了一个
使用者
,我
的
意思是,这个
使用者</em
浏览 2
提问于2016-01-11
得票数 8
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
NET Core使用NLog通过Kafka实现日志收集
Apache Kafka 2.0.0版本发布,多方面功能得到加强
“Kafka技术”Apache Kafka中的事务
“事件驱动架构”Apache Kafka中的事务
“消息中间件”Apache Kafka中的事务
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券