腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
我
可以
在运
行时
向
@
kafkalistener
添加
主题
吗
我
已经为
主题
数组创建了一个bean,并
在运
行时
向
该
主题
数组
添加
了一些
主题
,但是使用者没有更新
主题
,仍然从
主题
数组中的第一个
主题
开始消费。
我
希望消费者
添加
这些新的
主题
,并从它们开始消费 @Autowired @
KafkaListener
(topics = "#{
浏览 28
提问于2021-08-11
得票数 2
回答已采纳
1
回答
kafka
主题
消息的动态消费
、
、
、
我
需要使用生产者动态创建的
主题
中的消息。
我
在consumer @
KafkaListener
(topicPattern = "topicname_.*“)中使用了
主题
模式方法,还设置了metadata.max.age.ms=3000。但显然,除非我将offset.auto.reset设置为最早,否则
我
无法实现这一点。在我们的要求中,必须将offset.auto.reset设置为最新,以避免重复问题。有没有什么办法
可以
做到这一点?
浏览 3
提问于2019-12-09
得票数 0
1
回答
spring kafka @
KafkaListener
监听器容器?
、
有没有办法控制@
KafkaListener
使用的ListenerContainer对象?如果可能的话,
我
想使用容器动态订阅新的
主题
。或者有另一种更好的方式
在运
行时
订阅新
主题
?谢谢。-aj
浏览 20
提问于2020-06-14
得票数 0
回答已采纳
1
回答
卡夫卡消费者动态选择话题
、
、
、
我
在Spring中配置了一个Kafka消费者。Component private MessageProcessor messageProcessor; session.timeout.ms=3
浏览 0
提问于2019-01-31
得票数 3
回答已采纳
1
回答
动态弹簧卡夫卡听众
、
、
我
使用spring和SPEL,并试图根据其中一个属性文件中的值来聆听不同的
主题
。@
KafkaListener
(topics="#{kafkaTopics.getTopics().get('${key.in.property}')}")
我
要去接IllegalTopicException。无效
主题
'
浏览 1
提问于2019-03-04
得票数 0
回答已采纳
1
回答
动态启动和关闭
KafkaListener
,只是为了在会话开始时加载以前的消息
、
、
、
我
为
kafkalistener
编写了一个工作代码,用于从
主题
的(offset=0)开始读取消息(始终
在运
行)。对于我的用例(消息传递),
我
需要2件事: 总是捕获特定
主题
/分区的新消息(这个使用者总是
在运
行),并发送到前端websocket+stomp。(
我
已经有了这个部分)启动新的使用者以从开始到当前获取特定
主题
/分区的消息,只有在前端信号发出之后才停止,这样这些数据(为后期用户或以后的用户加载以前的消息)
浏览 7
提问于2020-05-22
得票数 0
4
回答
如何
在运
行时
向
方法
添加
属性?
、
、
、
工作方式是
向
事件
添加
一个属性,指定一个
主题
名,如下所示:public event EventHandlerExample;[EventSubscription("example", ThreadOption.Publisher)] public
我
可以
得到所有<e
浏览 10
提问于2008-11-06
得票数 14
回答已采纳
1
回答
如何
在运
行时
告诉spring-kafka消费者停止消费?
我
使用的是带有
KafkaListener
注释的spring-kafka v2.5.2。
在运
行时
,
我
希望能够
向
消费者发送停止消费的信号。
我
看到了autoStartup参数,但它似乎只在初始化时起作用,之后就不能更改了。
我
看到了KafkaListenerEndpointRegistry的方法close() ... 你有什么建议
吗
?
浏览 12
提问于2020-07-13
得票数 0
1
回答
Spring Kafka :
在运
行时
订阅新的
主题
模式
、
、
、
、
我
使用注解@
KafkaListener
在
我
的应用程序中使用
主题
。
我
需要
在运
行时
更改已
在运
行的使用者中的
主题
模式,以便
可以
使用与新模式匹配的新
主题
。
我
尝试了下面的代码,但它仍然使用与旧的
主题
模式匹配的
主题
。这里,
我
在应用程序启动时设置了"old-topic-pattern“。然后,
我
使用Spring @
浏览 3
提问于2019-06-10
得票数 0
1
回答
如何在c#中指定WPF
主题
?
、
、
、
我
发现
可以
在C# WPF应用程序中使用不同的
主题
,方法是将
主题
.xaml-file
添加
到项目中,然后
添加
将App.xaml作为资源。有关详细说明,请参阅。
向
Marc致以最好的问候
浏览 0
提问于2009-11-05
得票数 0
回答已采纳
1
回答
使@
KafkaListener
能够接受来自application.yml文件的变量
主题
名称
、
我
试图将多个
主题
加载到单个@
KafkaListener
中,但遇到了麻烦,因为
我
认为它正在寻找一个常量值,但初始化topics变量从application.yml文件导致一些问题,
我
想知道是否有人
可以
帮助我解决这个问题
我
可以
通过在逗号分隔的对象中传递多个
主题
来监听同一@
KafkaListener
中的多个
主题
,如下所示:
浏览 7
提问于2017-07-06
得票数 9
回答已采纳
3
回答
在spring-kafka中实现多KafkaListeners的共享逻辑
、
、
、
、
我
的Spring Boot应用程序包含几个,每个侦听器在实际处理有效负载之前和之后执行相同的步骤:验证有效负载,检查事件是否已经被处理,检查它是否是一个逻辑删除(null)消息,决定在失败的情况下是否应该重试处理这些步骤目前是在基类中实现的,但是因为传递给@
KafkaListener
的
主题
在运
行时
必须是常量,所以用@
KafkaListener
注释的方法是在子类中定义的,它只会将其参数传递给基类中的方法。
我
假设
我
的基类必须以编程方式创建一个侦听器容器,但
浏览 0
提问于2018-05-14
得票数 2
3
回答
每一个话题都有一条卡夫卡消费者的线索
吗
?
、
、
、
我们启用了并发性,因此每个分区
可以
有一个使用者线程。因此,目前,如果我们有3个
主题
,每个
主题
都有2个分区,那么将有2个使用者线程,如下所示:ConsumerThread2 -
主题
1-1,
主题
2-1,
主题
3-1Con
浏览 0
提问于2019-05-22
得票数 4
2
回答
在上
添加
分区需要一些时间才能有效
、
、
我
正在修改Kafka
主题
,
向
它
添加
分区(从3个分区到4个分区)。在使用者方面,
我
已经有4种并发性,使用@
KafkaListener
生产者每隔几秒钟发送一次消息在生产者开始
向
第4分区发送消息之前,大约花了5分钟的时间,还用了5分钟进行再平衡,从而使第4用户生效。 这是正常的
吗<
浏览 1
提问于2019-07-01
得票数 2
回答已采纳
1
回答
当不能授权时,为何spring KafkaConsumer会暂停n个
主题
的所有消费?
、
我
正在使用spring 2.3.6 consume库来使用大量的kafka
主题
。在接口允许的情况下,
我
使用单个侦听器来处理所有
主题
。
我
已经注意到,如果单个
主题
无法授权,KafkaConsumer实例将挂起它的线程,停止对所有
主题
的使用,直到重试间隔过去。 在我看来,这一点非常脆弱,特别是对于一项侧重于弹性和并行性的技术。
浏览 6
提问于2020-03-17
得票数 1
回答已采纳
1
回答
如何检查集成测试中是否调用了@
KafkaListener
?
、
、
、
我
想写一个完整的kafka流程的集成测试。在
我
的产品代码中,
我
有:public void listen(@Payload String payload) { // business logic here在
我
的测试代码中,
我</em
浏览 0
提问于2019-10-23
得票数 1
1
回答
将队列
添加
到OpenJMS
、
目前,
我
正在使用openJMS。
我
已经让示例正常工作了,但在这种情况下,
我
必须在管理页面中
添加
/编辑队列和
主题
。 是否
可以
以及如何在openJMS运
行时
动态
添加
队列?
我
想做的是,
在运
行时
创建和销毁
可以
向
JMS描述并具有自己的点对点队列的对象。
浏览 2
提问于2011-01-27
得票数 1
回答已采纳
1
回答
弹簧卡夫卡非阻塞重试
我
有批@
KafkaListener
,如下所示: topicPattern = "ProductTopic", containerFactory每次重试失败时,
我
都会
向
ProductTopic.Retry-#发布消息,并最终将其发送到ProductTopic.Retry-DLT。还让我们假设,由于其他一些限制,
我
不能让框架为
我
创建retry和dlt
主题</
浏览 7
提问于2022-06-15
得票数 0
2
回答
可能不公开还是无效?使用Spring的Websocket和Kafka
、
、
当我试图使用来自
主题
的数据时(
主题
名是基于用户的),
在运
行时
,
我
尝试使用来自
主题
的消息,但是
我
得到了以下错误。这是
我
的密码public class kafkaConsumerService { this.consumerProperties=consumerProperties; this.templat
浏览 0
提问于2018-09-10
得票数 2
1
回答
卡夫卡-连接
添加
更多的
主题
。
、
、
我
有一个在使用一些
主题
。org.apache.kafka.connect.storage.StringConverter", "topics": "topic1,topic2",}
我
可以
在运
行时
向
它
添加
更多
主题
吗
如果
我
从列表中删除一
浏览 1
提问于2019-03-22
得票数 2
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Java:Java代理如何影响你的代码
一文说透"静态代理"与"动态代理"
Flink高级应用模式第一辑:欺诈检测系统案例研究
Java帝国之风云再起
利用Python帮你快速获得大量真人粉丝
热门
标签
更多标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
活动推荐
运营活动
广告
关闭
领券