Skip to Content
PipelineKafka Connections

Supported Kafka Connections

GlassFlow supports connecting to Kafka clusters with multiple protocols and authentication methods. This page lists the supported options and how to configure them.

ℹ️

Configuration examples below refer to the pipeline source connection parameters. You can configure these via the Web UI or API.

Connection Protocols

Set the Security Protocol (protocol) according to your broker configuration:

  • PLAINTEXT
  • SASL_PLAINTEXT
  • SSL
  • SASL_SSL

SASL Authentication

Set one of the following Authentication Methods (mechanism):

  • PLAIN
  • SCRAM-SHA-256
  • SCRAM-SHA-512

On the UI, you can disable authentication entirely by selecting “No authentication” in the authentication method dropdown. On the Python SDK, you can set the skip_auth flag to true.

When authentication is enabled, the following fields are required:

  • mechanism (one of the above)
  • username
  • password

TLS Configuration

Enable TLS via protocol SSL/SASL_SSL and optionally supply root_ca to trust a custom CA.

Client certificate authentication (mTLS) is not supported.

Example Configurations

PLAINTEXT (no auth)

PLAINTEXT (no auth) example

SASL/PLAIN over TLS

SASL/PLAIN over TLS example

SASL/SCRAM-SHA-256

SASL/SCRAM-SHA-256 example

SSL (no SASL)

SSL (no SASL) example
Last updated on