Spring Cloud Stream производитель кафки, выпускающий динамику c тема кафки

Question

Я хотел бы создать конечную точку kafka, используя платформу Spring Cloud Stream, которая будет иметь http post api на /{topic_name}. Как я могу динамически изменить spring.cloud.stream.bindings.<channelName>.destination={topic_name} свойство

Я мог бы использовать confluent Kafka REST Proxy реализация для достижения вышеуказанной функциональности, но интересно, если это возможно, чтобы разработать это весной.

Answer 1

Вот пример, который демонстрирует эти типы случаев использования, когда он использует динамические c места назначения на основе триггера http. Взгляните на код и ЧТЕНИЕ.

https://github.com/spring-cloud/spring-cloud-stream-samples/tree/master/source-samples/dynamic-destination-source-kafka