Kafka Connector

Kafka Connector

Connecting to Amazon Managed Streaming for Apache Kafka

Connecting to Amazon Managed Streaming for Apache Kafka

In the Kafka connection, you can configure PLAINTEXT or TLS encryption to connect to an Amazon Managed Streaming for Apache Kafka broker. To read data from or write data to an Amazon Managed Streaming for Apache Kafka broker, configure the Kafka connection properties.
Configure the
Kafka Broker List
property in the Kafka connection and specify the comma-separated list of Kafka brokers that you want to connect to in the following format:
<HostName>:<PortNumber>
Configure TLS encryption to securely connect the Kafka broker to the Kafka producer and the Kafka consumer. To configure TLS encryption for an Amazon Managed Streaming for Apache Kafka broker, configure the following properties:
Property
Values
Additional Connection Properties
security.protocol=SSL
SSL Mode
One-way or Two-way.
SSL TrustStore File Path
Required when you use the one-way or two-way SSL mode.
Absolute path and file name of the SSL truststore file.
SSL TrustStore Password
Required when you use the one-way or two-way SSL mode.
Password for the SSL truststore.
SSL KeyStore File Path
Required when you use the two-way SSL mode.
Absolute path and file name of the SSL keystore file that contains private keys and certificates that the Kafka broker validates against the Kafka cluster certificate.
SSL KeyStore Password
Required when you use the two-way SSL mode.
Password for the SSL keystore.
When you run a mapping that runs on an advanced cluster and connect to an Amazon Managed Streaming for Apache Kafka broker, configure the Kafka broker using SASL_SSL authentication with Salted Challenge Response Authentication Mechanism (SCRAM). To read data from or write data to an Amazon Managed Streaming for Apache Kafka broker with SASL_SSL authentication, configure the following properties:
Property
Values
Additional Connection Properties
security.protocol=SASL_SSL,sasl.mechanism=SCRAM-SHA-512,sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="<username>" password="<password>";
SSL Mode
One-way or Two-way.
SSL TrustStore File Path
Required when you use the one-way or two-way SSL mode.
Absolute path and file name of the SSL truststore file.
SSL TrustStore Password
Required when you use the one-way or two-way SSL mode.
Password for the SSL truststore.
SSL KeyStore File Path
Required when you use the two-way SSL mode.
Absolute path and file name of the SSL keystore file that contains private keys and certificates that the Kafka broker validates against the Kafka cluster certificate.
SSL KeyStore Password
Required when you use the two-way SSL mode.
Password for the SSL keystore.

0 COMMENTS

We’d like to hear from you!