The Kafka forwarding agent (producer) is responsible for sending data to the Kafka log.
The Kafka forwarding agent in a real-time workflow
Note!
If a workflow is running, and the cluster goes down or a network connection issue occurs, the Kafka forwarding agent cannot send data to the cluster, and the following exception is logged:
NetworkException[org.apache.kafka.common.errors.NetworkException: The server disconnected before a response was received].
If this exception is logged, verify if the cluster is down or not. If the cluster is down, restart the cluster using the command mzsh service restart.