Skip to content

Forward Data to Kafka Message Queue

  1. Complete the setting of rule name and filter conditions;
  2. Continue configuring the archive.

Configuration

  1. Address: Host:Port, multiple nodes separated by commas;

  2. Message topic: the Topic name;

  3. Security protocol: On the Kafka side, SASL can use PLAINTEXT or SSL protocol as the transport layer, corresponding to using SASL_PLAINTEXT or SASL_SSL security protocols. If using SASL_SSL security protocol, SSL certificate must be configured;

  4. Click Test Connection, if the above information meets the specifications, it will prompt that the test connection is successful. Click OK to save the current rule.

If the test fails:

You need to confirm:

  • Address is correct
  • Message topic name is correct
  • SSL certificate is correct
  • Username is correct
  • Password is correct

PLAINTEXT

No security verification is required, you can directly test the connection.

SASL_PLAINTEXT

The authentication method defaults to PLAIN, with optional SCRAM-SHA-256 and SCRAM-SHA-512.

Enter the username/password for security authentication on the Kafka side, then test the connection.

SASL_SSL

Here SSL certificate needs to be uploaded.

The authentication method defaults to PLAIN, with optional SCRAM-SHA-256 and SCRAM-SHA-512.

Enter the username/password for security authentication on the Kafka side, then test the connection.