Label*

Default Value: Kafka MSK IAM Account
Example: Kafka_Client_Auth_MSK_IAM

String

Specify a unique label for the account.

Bootstrap servers*

Use this field set to specify the ordered list of host-port pairs to establish an initial connection to the Kafka cluster.

Bootstrap server

Default Value: N/A
Example: 

b-1.kafka-cluster-name.abcde.c5.kafka.us-west-2.amazonaws.com:9092

String/Expression

Specify a host-port pair that you use to establish an initial connection to the Kafka cluster.

Schema registry URL

Default Value: N/A
Example: http://localhost:8081

String/Expression

Specify the URL for the schema registry server.

Advanced Kafka properties

Use this field set to specify any additional properties for connection to the Kafka server that are not explicitly provided in the Snap.

Key

Default Value: N/A
Example: session.timeout.ms

String/Expression

Specify the key for the Kafka property that Snap does not explicitly support.

Value

Default Value: N/A
Example: 10000

Integer/Expression

Specify the value for the Kafka property that Snap does not explicitly support.

Security protocol

Default Value: SASL_SSL
Example: SSL

Select one of the following security protocols from the suggestions:

• SSL

• SASL_SSL

• SASL_PLAINTEXT

IAM Role

Default Value: Deselected

Checkbox

Select this checkbox to use the IAM role associated with the EC2 instance to access the MSK cluster.

Cross account IAM properties

AWS role ARN

Default Value: N/A
Example: arn:aws:iam::123456789012:role/KafkaProducerRole

String/Expression

Specify the ARN of the cross-account IAM role. This ARN defines the permissions and trust policies for assuming the role.

External ID

Default Value: N/A
Example: EXTERNAL_ID_VALUE

String/Expression

Specify the external ID to add an extra layer of security by preventing ‘confused deputy’ attacks.

AWS region

Default Value: N/A
Example: us-west-2

String/Expression

Specify the AWS region where the application is running.

Session duration (seconds)

Default Value: N/A
Example: 900

String/Expression

Specify the duration in seconds for which the assumed role session is valid.

Session name

Default Value: N/A
Example: client

String/Expression

Specify an identifier for the assumed role session. This identifier helps to uniquely identify a session when the same role is assumed by different entities.

Account validation failed.

The Pipeline ended before the batch could complete execution due to a connection error.

Verify that the Refresh token field is configured to handle the inputs properly. If you are not sure when the input data is available, configure this field as zero to keep the connection always open.