当前位置: 首页 > 知识库问答 >
问题:

当我使用ConvoltKafkaListenerContainerFactory时,如何拦截ConvoltMessageListenerContainer

凤财
2023-03-14

我正在使用spring-kafka-2.2.7。RELEASE并尝试在方法级别使用@KafkaListener与ConvoltKafkaListenerContainerFactory一起创建一个消费者。根据我的理解,这将创建一个ConvoltMessageListenerContainer。

>

如果我有两种不同的方法使用@KafkaListener来消费两个不同的主题,它会创建两个ContoptMessageListenerContainers吗?

共有1个答案

申高峯
2023-03-14

>

<代码>注册表。getListenerContainer(“foo”)。getContainerProperties()。setGroupId(…) 注册表。getListenerContainer(“foo”)。开始()

但是,您可以简单地使用

@KafkaListener(... groupId "${some.property}")

@KafkaListener(... groupId "#{someSpelExpression}")

如果您只想设置组id。

 类似资料:
  • 我正在尝试使用<code>网络客户端 谢谢 -斯里尼

  • 问题内容: 使用笑话进行测试时,我具有基本的测试服语法: 问题是我的代码中有拦截器,当使用jest命令输出运行测试时,拦截器会: TypeError:无法读取未定义的属性“拦截器” 并指向拦截器对象 是存储以下项的返回值的变量 在SO上引用了该axios线程。我如何以开玩笑的方式测试axios,但是它不涉及任何拦截器,因此并没有真正的帮助。 问题答案: 最后就足够了

  • 拦截时间 bp GetLocalTime 获取本地时间 bp GetSystemTime 获取系统时间 bp GetFileTime 获取文件时间 bp GetTickCount 获得自系统成功启动以来所经历的毫秒数 bp GetCurrentTime 获取当前时间(16位) bp SetTimer 创建定时器 bp TimerProc 定时器超时回调函数

  • 我根据JBoss文档创建了一个拦截器。 为了测试拦截器,我把: 现在,我想使用WeldJUnit4Runner类在单元测试中测试这个拦截器。 现在的预期产出当然是 但结果却是 主要问题是,如果我在测试中注入bean,这也是正确的:我调用的bean的第一个方法被拦截,但是如果这个方法调用另一个方法,拦截器就不会被调用。 任何想法都非常感谢! 我只是按照@adrobisch的建议修改了我的代码,效果如

  • 问题内容: 我知道如何拦截所有请求,但是我只想拦截来自我资源的请求。 有谁知道如何做到这一点? 问题答案: 如果只想拦截来自特定资源的请求,则可以使用可选的action 属性。Angular的文档请参见此处(用法>操作) 的JavaScript Plunker:http ://plnkr.co/edit/xjJH1rdJyB6vvpDACJOT?p=preview

  • 让我有一个这样的界面: 还有这样一个实现类: 现在我想使用bytebuddy创建一个拦截器/代理,它捕捉对setter的调用,存储更改后的值,并调用real方法。 最后,我想向拦截器/代理“询问”被调用的setter和更改的值。 我尝试了很多考虑也教程,但到目前为止,我发现没有工作的解决方案。也许有人可以帮助我。 这是拦截器: 以下是我当前的“测试”代码: 编辑: