.join(reply()). Details at https://github.com/krasserm/streamz/tree/master/streamz-camel-akka#receiving-in-out-message-exchanges-from-an-endpoint-1
reply()is nothing else than joining the identity flow: https://github.com/krasserm/streamz/blob/master/streamz-camel-akka/src/main/java/streamz/camel/akka/javadsl/JavaDsl.java#L101
DataFrameinto a JVM application. I've never worked with Dask nor do I know a library that loads Dask or Pandas data frames into a JVM application. Given that you find such a library (or have some other Java/Scala code that can read the data frame directly) you need to write a custom Akka Streams
Sourceor a custom FS2
Streamfor "loading" the read data into Streamz.