Skip to main content
Version: 5.4

Apache Kafka Plug-in

Apache Kafka Plug-in

You can set the following properties in the Apache Kafka plug-in configuration:

NameAssign a unique name to the Apache Kafka connection.
Broker connectionEnter the broker address. The port in the address is the port on the server used to connect to Apache Kafka.
SSLUses SSL encryption. The server must support this and the corresponding port must be set.
Client IDUse a unique client ID. You can generate a randomly created string using the "Generate" button.
Group IDUse a unique group ID. You can generate a randomly created character string using the "Generate" button.
UserIf user authentication is active, enter a user name.
PasswordIf user authentication is active, enter a password.
SASL mechanism

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

  • PLAIN: Authentication via user and password. These are stored locally in the Kafka configuration.
  • SCRAM-SHA-256/512: Login information is stored in Zookeeper. This option can be used if ZooKeeper cluster nodes are running in an isolated private network.
  • GSSAPI: Authentication with 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. Only Windows certificates or only router certificates.
Connection timeout (ms)Timeout in milliseconds before the transfer is considered failed.
Enable GzipMessages between the broker and OPC Router can be compressed. You can also determine the degree of compression.
Wait for transfer resultConfirms the successful Kafka transfer only when the router connection with the transfer result OK has been completed.
Consume Interval (s)Interval in which the trigger checks the topic.