Skip to main content

This content has been archived and is no longer being updated. Links may not function; however, this content may be relevant to outdated versions of the product.

Support Article

UnknownServerException occurs at destination in a dataflow



A real time dataflow is present with a Stream dataset as the source and a dataflow as the destination which in turn writes to a Stream dataset. Errors occur at the destination.

Error Messages

pega.dsm.dnode.api.ExceptionWithInputRecord: org.apache.kafka.common.errors.UnknownServerException: The server experienced an unexpected error when processing the request pega.dsm.dnode.impl.dataset.kafka.KafkaSaveOperation.failSingleRecord( pega.dsm.dnode.impl.dataset.kafka.KafkaSaveOperation.access$600( pega.dsm.dnode.impl.dataset.kafka.KafkaSaveOperation$1.emit($SafeDataSubscriber.subscribe( pega.dsm.dnode.api.dataflow.DataFlowStage$StageInputSubscriber.onPulse( pega.dsm.dnode.api.dataflow.DataFlowExecutor$QueueBasedDataFlowExecutor.runEventLoop( pega.dsm.dnode.api.dataflow.DataFlow$2.emit( pega.dsm.dnode.impl.dataflow.task.strategy.ExecutionStrategy.executeDataFlow(

Steps to Reproduce


Run a real time dataflow.

Root Cause

A defect in Pegasystems’ code or rules.


Perform the following local-change:
Increase the Retention period of the Stream dataset from 30 minutes to 12 hours.


Published August 19, 2019 - Updated December 2, 2021

Was this useful?

0% found this useful

Have a question? Get answers now.

Visit the Collaboration Center to ask questions, engage in discussions, share ideas, and help others.

Did you find this content helpful?

Want to help us improve this content?

We'd prefer it if you saw us at our best.

Pega Community has detected you are using a browser which may prevent you from experiencing the site as intended. To improve your experience, please update your browser.

Close Deprecation Notice
Contact us