> For clean Markdown of any page, append .md to the page URL. > For a complete documentation index, see https://mezmo.ferndocs.com/kafka-source/llms.txt. > For AI client integration (Claude Code, Cursor, etc.), connect to the MCP server at https://mezmo.ferndocs.com/_mcp/server. # Kafka ## 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 |