我正在用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字符串的消息?帮助我!
2条答案
按热度按时间ve7v8dk21#
使用--outputtype=text/plain或--outputtype=application/json。这两种方法都可以。它应该作为参数传递给流定义中的kafka源。
cidc1ykv2#
尝试在kafka源定义中使用option--encoding。