Search code examples
spring-cloudspring-cloud-streamspring-cloud-dataflow

Missing Kafka source/sink in springcloud

I would like to use Kafka Source/Sink in SpringCloud Dataflow but I cannot find thes app-starters in spring-cloud-stream-app-starters. They were available in Spring XD. Does anyone knows why they disappeared ?

Thanks

Solution

  • Use a named destination as the source/sink and set headerMode=raw if the producer (for a source) or consumer (for a sink) is not a Spring Cloud Stream app.

    dataflow:>stream create foo --definition ":myTopic > log --inputType=text/plain"

dataflow:>stream deploy --name foo --properties app.log.consumer.headerMode=raw