spring-xd kafka接收器(文件)编写ascii代码

Question

我在用spring测试apache。

我就是这样做的。http://spring.io/blog/2015/04/15/using-apache-kafka-for-integration-and-data-processing-pipelines-with-spring

它工作得很好，我是tring spring-xd。

xd> stream create kafka-source-test --definition "kafka --zkconnect=localhost:2181 --topic=event-stream | log" --deploy

我给卡夫卡发了条绳。

{“名称”：“tester1”，“年龄”：“0”}

它可以工作，但是log是

INFO dispatcher-1 sink.kafka-source-test - [B@2907e63b

所以我试着sink.file

xd> stream create kafka-source-test --definition "kafka --zkconnect=localhost:2181 --topic=event-stream | file" --deploy

查看输出文件，我遇到了这个ascii代码。

123,34,110,97,109,101,34,58,34,116,101,115,116,101,114,50,34,44,34,97,103,101,34,58,49,125

意思是这条绳子。

{“名称”：“tester1”，“年龄”：“0”}

如何使用json字符串获得消息？帮帮我!

Answer 1

使用--outputType=text/平原或--outputType=application/json。这两种方法都是可行的。在流定义中，它应该作为一个参数传递给kafka源。

Answer 2

尝试在kafka源代码定义中使用选项编码。