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