springcloud 中缺少 Kafka 源/接收器答案

【问题标题】：Missing Kafka source/sink in springcloudspringcloud 中缺少 Kafka 源/接收器
【发布时间】：2017-08-11 08:56:30
【问题描述】：

我想在 SpringCloud Dataflow 中使用 Kafka Source/Sink，但我在 spring-cloud-stream-app-starters 中找不到这些 app-starters。它们在 Spring XD 中可用。有谁知道他们为什么消失？

谢谢

【问题讨论】：

您可以在这里找到它们：source-> github.com/spring-cloud/spring-cloud-stream-samples/tree/master/… 和 sink-> github.com/spring-cloud/spring-cloud-stream-samples/tree/master/…。

标签： spring-cloud spring-cloud-stream spring-cloud-dataflow

【解决方案1】：

如果生产者（对于源）或消费者（对于接收器）不是 Spring Cloud Stream 应用程序，则使用 named destination 作为源/接收器并设置 headerMode=raw。

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

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

【讨论】：