Kafka Scram Sink
Provided by: "Apache Software Foundation"
Support Level for this Kamelet is: "Preview"
Send data to Kafka topics through SCRAM login module.
Configuration Options
The following table summarizes the configuration options available for the kafka-scram-sink
Kamelet:
Property | Name | Description | Type | Default | Example |
---|---|---|---|---|---|
Bootstrap Servers | Required Comma separated list of Kafka Broker URLs. | string | |||
Password | Required Password to authenticate to kafka. | string | |||
Topic Names | Required Comma separated list of Kafka topic names. | string | |||
Username | Required Username to authenticate to Kafka . | string | |||
SASL Mechanism | The Simple Authentication and Security Layer (SASL) Mechanism used. | string | SCRAM-SHA-512 | ||
Security Protocol | Protocol used to communicate with brokers. SASL_PLAINTEXT, PLAINTEXT, SASL_SSL and SSL are supported. | string | SASL_SSL |
Dependencies
At runtime, the kafka-scram-sink
Kamelet relies upon the presence of the following dependencies:
-
camel:core
-
camel:kafka
-
camel:kamelet
Camel JBang usage
Prerequisites
-
You’ve installed JBang.
-
You have executed the following command:
jbang app install camel@apache/camel
Supposing you have a file named route.yaml with this content:
- route:
from:
uri: "kamelet:timer-source"
parameters:
period: 10000
message: 'test'
steps:
- to:
uri: "kamelet:kafka-scram-sink"
You can now run it directly through the following command
camel run route.yaml
Kafka Scram Sink Kamelet Description
SCRAM Authentication
This Kamelet uses SCRAM (Salted Challenge Response Authentication Mechanism) for secure authentication with Kafka brokers. SCRAM provides a secure method for username/password authentication.
Authentication Mechanism
The Kamelet supports SCRAM-SHA-512 by default, which provides strong cryptographic security. The authentication mechanism can be configured based on the Kafka broker’s security configuration.
Security Protocol
Uses SASL_SSL security protocol by default, ensuring both authentication and encryption for data in transit. This provides comprehensive security for Kafka communications.