Question
Cognizant
IN
Last activity: 27 Feb 2020 15:07 EST
Exception while retrieving data from external kafka using Data Flow
Hi,
Created a Data Set and Configured the Data Flow to retrieve the message from External Kafka Queue. While executing the Data Flow, getting the few records failed with below exception.
$Worker.run(ThreadPoolExecutor.java:624) at com.pega.dsm.dnode.util.PrpcRunnable$1.run(PrpcRunnable.java:44) at com.pega.dsm.dnode.util.PrpcRunnable$1.run(PrpcRunnable.java:41) at com.pega.dsm.dnode.util.PrpcRunnable.execute(PrpcRunnable.java:52) at com.pega.dsm.dnode.impl.prpc.PrpcThreadFactory$PrpcThread.run(PrpcThreadFactory.java:109) Caused by: com.pega.dsm.dnode.api.ExceptionWithInputRecord: java.util.NoSuchElementException ... 19 more Caused by: java.util.NoSuchElementException at java.util.LinkedList.removeFirst(LinkedList.java:270) at java.util.LinkedList.pop(LinkedList.java:801) at com.pega.dsm.dnode.util.ClipboardPageJsonConverter.adoptJson(ClipboardPageJsonConverter.java:250) 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
Thanks,
Vadivel M
Pegasystems Inc.
IN
Hi Vadivel ,
Please try this.
Browse the data set (to check clipboard structure) and create the properties and the pages on the Pega side as per the clipboard structure.
Hope this helps.
Thanks,
Rakesh