Kafka

Current version v0.0.1

See the changelog of this Listener type here.

Overview

Onum supports integration with Kafka. Select Kafka from the list of Listener types and click Configuration to start.

This is a Pull listener, therefore should not be used in environments with more than one cluster.

Configuration

Now you need to specify how and where to collect the data, and how to establish a connection with Kafka.

Metadata

Enter the basic information for the new Listener.

Parameter	Description
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.

---

Configuration

Now add the configuration to establish the connection.

Parameter	Description
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.
Group ID	The group ID is a string that uniquely identifies the group of consumer processes. Find this in your Kafka Cluster Home>Configuration>Consumer Properties.
Topics	The topic to connect to. Use kafka-topics --bootstrap-server :9092 --describeand write the result here.
Auto offset reset policy*	The auto.offset.reset policy defines the behavior when there are no committed positions available or when an offset is out of range. Choose between Eariest, Latest, None.

Select Finish and see your Listener appear in the list of Listeners.

Click Create labels to move on to the next step and define the required Labels if needed.