0

我想在SpringCloud Dataflow中使用Kafka源/接收器,但我無法在spring-cloud-stream-app-starters中找到這些應用程序啓動器。 它們在Spring XD中可用。有誰知道他們爲什麼消失?在springcloud中缺少Kafka源/接收器

感謝

+0

你可以在這裏找到他們:源 - > https://github.com/spring-cloud/spring-cloud-stream-samples/tree/master/source和sink-> https://開頭github上。 com/spring-cloud/spring-cloud-stream-samples/tree/master/sink。 – MojoJojo

回答

0

使用named destination作爲源/匯,並設置headerMode=raw如果生產者(對於源)或消費者(對於匯)是不是一個春天的雲Stream應用程序。

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

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