Apache Kafka
Most recent version: v2.0.0
Last updated
Was this helpful?
Most recent version: v2.0.0
Last updated
Was this helpful?
This is a Pull Listener and therefore should not be used in environments with more than one cluster.
Onum supports integration with Apache Kafka. Select Apache Kafka from the list of Listener types and click Configuration to start.
Now you need to specify how and where to collect the data and how to establish a connection with Apache Kafka.
Enter the basic information for the new Listener.
Name*
Enter a name for the new Listener.
Description
Optionally, enter a description for the Listener.
Tags
Add tags to easily identify your Listener. Hit the Enter key after you define each tag.
Now, add the configuration to establish the connection.
Bootstrap Servers
The initial host-port pair that acts as the starting point to access the full set of alive servers in the cluster. This is a comma-separated list of host and port pairs using : as the separator, e.g. localhost:9092,another.host:9092
Enter your value and click Add element to add the required elements.
Group ID
The group ID is a string that uniquely identifies the group of consumer processes. Find this in your Kafka Cluster at Home > Configuration > Consumer Properties.
Topics
The topic to connect to. Use kafka-topics --bootstrap-server :9092 --describe and write the result here.
Auto offset reset policy*
This policy defines the behavior when there are no committed positions available or when an offset is out of range. Choose between Eariest, Latest, or None.
Authentication
Leave as None or select the authentication type to enable the settings:
Plain
Username
Password
Scram
Username
Password
SCRAM Mechanism* - Either SHA-256 and SHA-512.
TLS
CA Certificate - The path containing the CA certificates.
Certificate* - This is the predefined TLS certificate.
Client key*- The private key of the corresponding certificate.
Skip Verify - Select true to skip or false to require verification.
Server Name - Enter the name of the server to connect to.
Minimum TLS version* - Select the required version from the menu.
Click Create labels to move on to the next step and define the required Labels if needed.
