You are here:Integrations > Kafka
Kafka is a publish-subscribe message queuing system that's designed like a distributed commit log. Netuitive can help monitor the performance and throughput of your Kafka server with our integration that's easy to set-up.
Important If you haven't installed the Linux agent already, see the instructions on this page for how to install it. If you need to disable the Linux integration or view the unique API key assigned to your account, navigate to the Integrations page under the user account drop-down menu and click the integration designated as Infrastructure under the Integration column.
- Install the latest binary of MX4J. MX4J is an open source implementation of the Java Management Extension (JMX) technology. You can read more about it here.
- Copy the MX4J jars to your Kafka libs folder.Example(s) For the 3.0.2 Binary version of MX4J, the libs are in this location: ...\mx4j-3.0.2\lib\
- In your kafka-server-start.sh script, add the following line:
export KAFKA_JMX_OPTS="-Dmx4jport=8082 -Dmx4jaddress=127.0.0.1 -Dmx4jenable=true"
- Restart your Kafka server now that your start shell script has been updated.
- Navigate to the collectors folder.Note The default location is at /opt/netuitive-agent/conf/collectors.
- Open the KafkaCollector.conf file.
- Change the enabled setting to True.
- Save the file, and restart the Linux Agent.
Additional Configuration Options
|enabled||False||Enable collecting Kafka metrics.|
|byte_unit||Default numeric output(s).|
|host||Hostname/IP address to collect from.|
|measure_collector_time||Measure the collector's run time in milliseconds.|
|metrics_blacklist||Regex list to match metrics to block. Mutually exclusive with metrics_whitelist option.|
|metrics_whitelist||Regex list to match metrics to transmit. Mutually exclusive with metrics_blacklist option.|
|port||Port to collect from.|