Home > Software design >  Spring cloud stream : Attempted to pause a component that does not support Pausable bean
Spring cloud stream : Attempted to pause a component that does not support Pausable bean

Time:03-04

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..

CodePudding user response:

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.

CodePudding user response:

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

  • Related