Question

9
Replies
1148
Views
NIKUBHAN Member since 2009 14 posts
PayPal
Posted: 1 year ago
Last activity: 10 months 4 weeks ago
Solved

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:

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***

Data Integration SR Parallel
Share this page LinkedIn