Kafka Forwarding Agent

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.