Spring Cloud Stream:尝试暂停不支持Pausable bean的组件
我是春天云流的新手。我正在使用我们的一位团队成员编写的活页夹。 我使用执行器的 /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 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论
评论(2)
您的绑定是匿名的,因为
group
名称是根据函数名称生成的。这就是错误消息告诉您的内容。您必须明确声明组名称。您可以获取更多信息 这里
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.You can get more info here
它不是活页夹,而是实际代理的底层功能。只有 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.