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