Error in Kafka Save Operation: Caught exception: com.pega.dsm.dnode.api.BatchRecordException
I am doing a POC to connect to Kafka from my Pega 7.3.1 application.
Created the Data Set & the Kafka configuration instance & successfully did a Test Connection form both.
Created an activity & used the DataSet-Execute method to perform Save Operation in an existing Kafa queue. Checked the checkbox (Save List of Pages defined in a Named Page) & provided the Code-Pega-List page name (with one record in pxResults(1) with a few properties)
On executing the activity I am getting the below error stack trace:
I am doing a POC to connect to Kafka from my Pega 7.3.1 application.
Created the Data Set & the Kafka configuration instance & successfully did a Test Connection form both.
Created an activity & used the DataSet-Execute method to perform Save Operation in an existing Kafa queue. Checked the checkbox (Save List of Pages defined in a Named Page) & provided the Code-Pega-List page name (with one record in pxResults(1) with a few properties)
On executing the activity I am getting the below error stack trace:
Caught exception: com.pega.dsm.dnode.api.BatchRecordException
com.pega.dsm.dnode.api.BatchRecordException$Builder.build(BatchRecordException.java:66)
com.pega.dsm.dnode.impl.dataset.kafka.KafkaSaveOperation$2.emit(KafkaSaveOperation.java:198)
com.pega.dsm.dnode.impl.stream.DataObservableImpl$SafeDataSubscriber.subscribe(DataObservableImpl.java:335)
com.pega.dsm.dnode.impl.stream.DataObservableImpl.subscribe(DataObservableImpl.java:53)
com.pega.dsm.dnode.impl.stream.DataObservableImpl.await(DataObservableImpl.java:99)
com.pega.dsm.dnode.impl.stream.DataObservableImpl.await(DataObservableImpl.java:88)
com.pegarules.generated.activity.sh_action_kafkaconnector_5a47491e6a6d65ed69fa439626fbfd98.step6_circum0(sh_action_kafkaconnector_5a47491e6a6d65ed69fa439626fbfd98.java:455)
com.pegarules.generated.activity.sh_action_kafkaconnector_5a47491e6a6d65ed69fa439626fbfd98.perform(sh_action_kafkaconnector_5a47491e6a6d65ed69fa439626fbfd98.java:165)
***Edited by Moderator Marissa to update SR Details***
Accepted Solution
Pegasystems Inc.
IN
Hello @NIKUBHAN,
Upon reviewing the SR, the resolution was as follows:
Disable 'AppDynamics' of Kafka correlation at Kafka side.
Evonsys
IN
Hi Nikubhan,
Did you find any solution for this issue as I am also facing the same issue today.
SR-C82972 on this.
Can you please help me incase of any solution to publish data on kafka and also I have to remove pxObjClass and pxAutomationProperties from JSON. Below is my parsed code using data-transform Serialize.
{"pxObjClass":"BFS-FW-OLPRB-Data","data":{"pxObjClass":"BFS-FW-OLPRB-Data-AppData","applicationNumber":"190000002435","docType":"Suresh"},"pxAutomationResults":[]}
Accepted Solution
Pegasystems Inc.
IN
Hello @NIKUBHAN,
Upon reviewing the SR, the resolution was as follows:
Disable 'AppDynamics' of Kafka correlation at Kafka side.
LeasePlan Digital B.V.
NL
Getting a similar error in 8.2 Pega Version , My activity is just calling Property-Set where I am mapping the string to send and DataSet-Execute method.
Please help if somebody have any information.
Java Exception: java.lang.RuntimeException: com.pega.dsm.dnode.api.BatchRecordException
Pegasystems Inc.
US