9.48.4 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.

This section includes the following subsections: