Skip to main content

Apache Kafka Plug-in

Apache Kafka Plug-in

You can configure the following properties in the Apache Kafka plug-in settings:

NameAssign a unique name to the Apache Kafka connection.
Broker ConnectionEnter the broker's address. The port in the address is the port on the server used for the connection to Apache Kafka.
SSLUses SSL encryption. The server must support this, and the corresponding port must be configured.
Client IDUse a unique client ID. Click the “Generate” button to generate a random string.
Group IDUse a unique Group ID. Click the “Generate” button to generate a random string.
UserIf user authentication is enabled, enter a username.
PasswordIf user authentication is enabled, enter a password.
SASL mechanism

Used for authentication. SASL authentication is supported over both unencrypted and TLS connections. You have the following options:

  • PLAIN: Authentication via username and password. These are stored locally in the Kafka configuration.
  • SCRAM-SHA-256/512: Credentials are stored in ZooKeeper. This option can be used when ZooKeeper cluster nodes are running on an isolated private network.
  • GSSAPI: Authentication via the Kerberos server.
Client CertificateSelect a client certificate from the drop-down list, which the OPC Router sends along with the request.
Trusted CertificatesSelect which certificates should be accepted: Windows certificates only or router certificates only.
Connection timeout (ms)Timeout in milliseconds before the transfer is considered to have failed.
Enable GzipMessages between the broker and the OPC Router can be compressed. You can also specify the compression level.
Wait for transmission resultConfirms the successful Kafka transfer only after the router flow has been completed with a transfer result of "OK."
Consume Interval (s)Interval at which the trigger checks the topic.