In our project we have multiple Spring boot micro services that consume the message using Kafka and send the message to another kafka topic and we have created a common spring library that uses Spring cloud stream kafka binder to consume and sending the messages to the another topic.
All the microservices are using this common library and passing inputTopic,outputTopic and errorTopic names. There is a requirement to create the binders dynamically based on spring.cloud.stream.function.definition.