xd-kafka-sink(文件)写ascii码

tyu7yeag  于 2021-06-08  发布在  Kafka
关注(0)|答案(2)|浏览(256)

我正在用springxd测试apachekafka。
我遵循这个例子。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

我把json字符串发送给Kafka。
{“name”:“tester1”,“age”:“0”}
它工作,但日志是

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

所以我试着沉下去

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字符串的消息?帮助我!

ve7v8dk2

ve7v8dk21#

使用--outputtype=text/plain或--outputtype=application/json。这两种方法都可以。它应该作为参数传递给流定义中的kafka源。

cidc1ykv

cidc1ykv2#

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

相关问题