 <blockquote> <p>Issue 1: Accessing web GUI of dockerized Spring Cloud Dataflow</p> </blockquote> <p>We might need little more details around this. Assuming this is the local-server, perhaps you could share the docker scripts/image, so we could try it out.</p> <blockquote> <p>Issue 2: Routing by JSON Header</p> </blockquote> <p>The <a href="https://github.com/spring-cloud/spring-cloud-stream-app-starters/tree/master/router/spring-cloud-starter-stream-sink-router" rel="nofollow"><code>router-sink</code></a> application would come handy for this type of use-cases. This application routes the payload to named destinations based on certain conditions, so you'd have the opportunity to route the payload with respective <code>ingest-query</code> to Cassandra. </p> <p>stream 1:</p> <pre><code>stream create test --definition "file | router --expression=header.contains('a')?':foo':':bar’" </code></pre> <p>stream 2:</p> <pre><code>stream create baz --definition ":foo &gt; cassandra --ingest-query=\"query1\"" </code></pre> <p>stream 3:</p> <pre><code>stream create wiz --definition ":bar &gt; cassandra --ingest-query=\"query2\"" </code></pre> <p>(<em>where: <code>foo</code> and <code>bar</code> are named destinations</em>)</p>