Cloud Stream Extension (FRESH)

extended.to("output-topic");