0

SpringCloud Dataflow에서 Kafka Source/Sink를 사용하고 싶습니다.하지만 spring-cloud-stream-app-starters에서 app-starters를 찾을 수 없습니다. 스프링 XD에서 사용할 수 있습니다. 왜 그들이 사라 졌는지 아는 사람 있습니까?springcloud에서 Kafka 소스/싱크가 누락되었습니다.

감사

+0

당신은 여기에서 찾을 수 있습니다 : 소스 -> https://github.com/spring-cloud/spring-cloud-stream-samples/tree/master/source 및 sink->은 https : // github에. co.kr/spring-cloud/spring-cloud-stream-samples/tree/master/sink에 있습니다. – MojoJojo

답변

0

소스/싱크으로 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