New Spring Cloud Stream Dynamic Topic Publish Sample!

That's pretty interesting. I think I can use this nicely with my https://github.com/solacese/topic-serialization project. It provides a reflection-based implementation of topic serialization via a template string like:

Stores/{state}/{storeNumber}/Order/{orderId}/{action}

I use it in Publishers to dynamically construct a topic string by passing in an object, and in Subscribers construct an intelligent subscription string based on a map of queries. Separates out the dynamic topic serialization just like we normally do with payload serialization; guessing it would look something like this (not a Spring guru)?

    @Autowired
    TopicStrategy<Order> strategy;
    @Bean
    public Consumer<Order> functionUsingStreamBridge(StreamBridge streamBridge) {
        return order -> {
            String topic = strategy.makeTopic(order);
            log.info("Processing order: " + order);
            streamBridge.send(topic, order);
        };
    }