I am trying to configure a data flow which can read data from Kafka topic. When I configure a long running thread to read from the topic, the below error is being thrown.

Note: Data posted to this topic is encrypted proto buff.

How does a data flow read data from topic? Does it try to parse it or will it place the payload on a temp page? Can we trace this read operation?

Cannot parse json at com.pega.dsm.dnode.util.ClipboardPageJsonConverter.adoptJson(ClipboardPageJsonConverter.java:365) at com.pega.dsm.dnode.util.ClipboardPageJsonConverter.adoptJson(ClipboardPageJsonConverter.java:197) at com.pega.dsm.dnode.impl.dataset.kafka.KafkaBrowseOperation.convertRecordToClipboardPage(KafkaBrowseOperation.java:184) at com.pega.dsm.dnode.impl.dataset.kafka.KafkaBrowseOperation.processRecords(KafkaBrowseOperation.java:160) ... 18 more Caused by: com.fasterxml.jackson.core.JsonParseException: Illegal character ((CTRL-CHAR, code 19)): only regular white space (\r, \n, \t) is allowed between tokens at [Source: com.pega.dsm.dnode.util.ClipboardPageJsonConverter$ByteBufferInputStream@10214ab9; line: 2, column: 2] at com.fasterxml.jackson.core.JsonParser._constructError(JsonParser.java:1586) at com.fasterxml.jackson.core.base.ParserMinimalBase._reportError(ParserMinimalBase.java:521) at com.fasterxml.jackson.core.base.ParserMinimalBase._throwInvalidSpace(ParserMinimalBase.java:472) at