Table of Contents
Key Features
- Kafka-to-Kafka pipelines: bridge event streams between clusters with Popsink transformations applied in flight.
- Broad authentication support: PLAINTEXT, SSL, and SASL (PLAIN, SCRAM-SHA-256, SCRAM-SHA-512, OAUTHBEARER, GSSAPI).
- Topic passthrough: output topic names follow your subscription configuration — no renaming is imposed by the target.
Prerequisites
- A reachable Kafka cluster to use as the sink.
- Credentials with permission to produce to the target topics (and to create them, if they don’t pre-exist and auto-creation is disabled on the cluster).
Configuration
| Field | Required | Description |
|---|---|---|
| Bootstrap Servers | Yes | Comma-separated host:port pairs for the target cluster (e.g. kafka1.example.com:9092,kafka2.example.com:9092) |
| Security Protocol | Yes | PLAINTEXT, SSL, SASL_PLAINTEXT, or SASL_SSL |
| SASL Mechanism | With SASL | PLAIN, SCRAM-SHA-256, SCRAM-SHA-512, OAUTHBEARER, or GSSAPI |
| SASL Username / Password | With SASL | Credentials for the chosen SASL mechanism |
Security Protocols
| Protocol | Encryption | Authentication |
|---|---|---|
PLAINTEXT | None | None — development only |
SSL | TLS | TLS client certificates (optional) |
SASL_PLAINTEXT | None | SASL |
SASL_SSL | TLS | SASL — recommended for production |