Getting Started with the Mezmo Platform
Manage Source Data
Build Telemetry Pipelines
Monitor Data and Create Alerts
Pipeline Destinations
Pipeline Processors
Reference
Other Mezmo Resources
Title
Message
Create new category
What is the title of your new category?
Edit page index title
What is the title of the page index?
Edit category
What is the new title of your category?
Edit link
What is the new title and URL of your link?
Kafka
Copy Markdown
Open in ChatGPT
Open in Claude
Connect to Cursor
Connect to VS Code
Description
This is a pull source. You can enable a source within Pipeline to collect events from Kafka compatible brokers.
Configuration
You can configure the source as described in the table below.
Configuration Options
| Option | Description |
|---|---|
| Title | Title of your source |
| Description | Description of your source |
| Brokers | A broker is an array of key/value pairs for each host and port of a Kafka broker |
| Host | The host name of IP address of the broker |
| Port | The port that the broker listens on |
| Topics | List of Kafka topic names to read events from |
| Consumer Group | The consumer group name to be used to consume events from Kafka |
| TLS Enabled | On/off toggle for using TLS for outgoing messages |
| SASL/SCRAM | On/off toggle for authentication |
| Decoding | Choose from bytes or JSON |
| SASL | Choose from plain, SCRAM-SHA-512, or SCRAM-SHA-256 |
| Username | The SASL/SCRAM username |
| Password | The SASL/SCRAM password |
Type to search, ESC to discard
Type to search, ESC to discard
Type to search, ESC to discard
Last updated on May 22, 2023
Was this page helpful?
Next to read:
LogStashDiscard Changes
Do you want to discard your current changes and overwrite with the template?
Archive Synced Block
Message
Create new Template
What is this template's title?
Delete Template
Message