spring-xd kafka sink(file)写入ascii码

spring-xd kafka sink(file) write ascii code

我正在使用 spring-xd 测试 apache-kafka。

我正在学习这个例子。 http://spring.io/blog/2015/04/15/using-apache-kafka-for-integration-and-data-processing-pipelines-with-spring

它工作正常，我正在尝试 spring-xd.

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

我向kafka发送json字符串。

{"name":"tester1","age":"0"}

有效但日志是

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

意思是这个json字符串。

{"name":"tester1","age":"0"}

如何获取带有 json 字符串的消息？ 帮帮我！

尝试在 kafka 源定义中使用选项 --encoding。

使用 --outputType=text/plain 或 --outputType=application/json。这两个都应该有效。它应该作为参数传递给流定义中的kafka源。