Skip to main content
Version: NG-3.1

Kafka Data Collector

Introduction

The Kafka Data Collector O11ySource reads from the configured Kafka cluster and ingests the selected topics into vuSmartMaps. It is intended for centralized collection of Kafka-based telemetry and enables downstream analysis in the platform.

Getting Started

Compatibility

vuSmartMaps supports the collecting data from the configured topic from a kafka cluster

Data Collection Method

vuSmartMaps collects Kafka Data Collector metrics through a data collector deployed within the vuSmartMaps platform, which uses kafka_consumer plugin to retrieve performance and health metrics.

Prerequisites

Inputs for Configuring Data Source

  • Name: Unique identifier for the source
  • Client Kafka Bootstrap Server: Enter the client kafka bootstrap server. Separate multiple broker by comma.
  • Client Kafka Topics: Enter the topics to be consumed. Use comma separated for multiple topics.
  • Destination Kafka Topic: Enter the destination kafka topic
Applications

Firewall Requirement

To collect data from this O11ySource, ensure the following ports are opened:

Source IPDestination IPDestination PortProtocolDirection
vuSmartMaps Collection/Ingress node IPIP address or FQDN of the Kafka Data Collector service9092*/9093*/9094*/9096*TCPOutbound

*Before providing the firewall requirements, please update the port based on the customer environment.

Configuring the Target

To verify that your Kafka broker is reachable from your vuSmartMaps cluster, run the following command. Replace <broker_ip> with the actual IP address of your Kafka broker.


nc -vz <broker_ip> 9092

If the connection is successful, you should see an output similar to:


Connection to <broker_ip> 9092 port [tcp/*] succeeded!

Configuration Steps

Metrics Collected

The metrics are based on the input data collected.