Я тестирую apache-kafka с помощью spring-xd.
Я следую этому примеру. 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.
{"имя":"тестер1","возраст":"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.
{"имя":"тестер1","возраст":"0"}
Как я могу получить сообщение с помощью json String? Помоги мне!
