Spring Cloud Stream:尝试暂停不支持Pausable bean的组件

发布于 2025-01-11 10:09:57 字数 488 浏览 0 评论 0原文

我是春天云流的新手。我正在使用我们的一位团队成员编写的活页夹。 我使用执行器的 /bindings 端点来暂停/恢复应用程序中的使用者。但我收到错误

o.s.c.s.b.AbstractMessageChannelBinder$2 : Attempted to pause a component that does not support Pausable bean 'XXX'

Qn 1。我猜这是因为我使用的活页夹不支持暂停/恢复操作。有人可以给我指出一些示例,在其中我可以找到如何将此功能添加到活页夹中吗?

Qn 2.我也尝试使用执行器端点启动/停止。停止工作正常,但是在启动时,我收到以下错误

o.s.c.s.b.AbstractMessageChannelBinder$2 : Can not re-bind an anonymous binding

有人也可以提供一些有关此错误的输入吗?

I'm new to spring cloud stream. I am using a binder written by one of our team members.
I use the /bindings endpoint of actuator to pause/resume a consumer in my application. But I'm getting an error

o.s.c.s.b.AbstractMessageChannelBinder$2 : Attempted to pause a component that does not support Pausable bean 'XXX'

Qn 1. I'm guessing it's because the binder that I'm using is not supporting the pause/resume operations. Can anybody point me to some examples, where I can find how to add this feature to the binder ?

Qn 2. I tried start/stop also using the actuator endpoint. Stop is working fine but, while doing start, I'm getting the below error

o.s.c.s.b.AbstractMessageChannelBinder$2 : Can not re-bind an anonymous binding

Can someone give some inputs regarding this error too..

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(2

绝不服输 2025-01-18 10:09:57

您的绑定是匿名的,因为 group 名称是根据函数名称生成的。这就是错误消息告诉您的内容。您必须明确声明组名称。

spring.cloud.stream.bindings.uppercase-in-0.destination=myDestination
spring.cloud.stream.bindings.uppercase-in-0.group=myGroup

您可以获取更多信息 这里

Your binding is anonymous since group name is generated based on the function name. And that is what the error message is telling you. You have to explicitly declare a group name.

spring.cloud.stream.bindings.uppercase-in-0.destination=myDestination
spring.cloud.stream.bindings.uppercase-in-0.group=myGroup

You can get more info here

将军与妓 2025-01-18 10:09:57

它不是活页夹,而是实际代理的底层功能。只有 Kafka 支持暂停,暂停在 Kafka 中具有特殊含义;其中暂停消费者不会导致消费者重新平衡,而停止消费者则会。

It's not the binder, rather the underlying functionality of the actual broker. Only Kafka supports pausing which has a special meaning within Kafka; where pausing the consumer will NOT cause consumer rebalancing while stopping consumer will.

~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文