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