Как напечатать новую строку в консоли kafka для потребителей - PullRequest
Новая
       12

Как напечатать новую строку в консоли kafka для потребителей

0 голосов
/ 24 сентября 2018

Я пытаюсь отправить некоторые данные (после присоединения KStream к KTable) в выходную тему " Topic-B " в следующем формате: 

{"Key":"1234"}
{"value":"#1#Hello#ABC#CDF#ZZ["XYZ"]"
  Date:2018-09-24 11:25:02

 &&MELLO" 
}

(там есть наблюдатель)это новая строка после первой строки (значения) и еще одна новая строка после «даты»)

Пока что я могу получить результат «KStream to Ktable» в теме вывода «* 1008»* Topic-B", но в следующем формате: 

{"Key":"1234"} {"value":"#1#Hello#ABC#CDF#ZZ["XYZ"]"Date:2018-09-24 11:25:02&&MELLO"}

(смотрите все в одной строке)

Я устал использовать newLine" \ n ", как показано ниже:

StringBuilder sb = new StringBuilder();
sb.append("#"+tokens[1] + "**\n**");
sb.append("Date: "+sdf.format(date)+"**\n\n**");                    
sb.append("&&MELLO");

Но данные в "Topic-B" выглядят следующим образом: 

{"Key":"1234"} {"value":"#1#Hello#ABC#CDF#ZZ["XYZ"]"**\n**Date:2018-09-24 11:25:02**\n\n**&&MELLO"}

(Наблюдатель, что "\ n" также печатается (используя Kafka-avro-console-потребитель) в одну строку)

Может ли кто-нибудь помочь мне решить эту проблему?или предложить какой-нибудь другой способ сделать это?Кстати, я использую Confluent-5.0.0 с zookeeper, kakfa и SchemaRegistry.

Заранее спасибо.

...