HomeDocumentationRecipesChangelog
HomeRequest DemoContact
Documentation
HomeRequest DemoContact

Kafka

Prepare credentials and permission in Kafka

Certain credentials and permission are required for Validio to validate your data:

  • Access and permissions to the specific Kafka clusters.

๐Ÿ“˜

Permissions and roles

Certain permissions and roles are required for the service account.
For more information, refer to Kafka security documentation and Confluent: Kafka SASL/PLAIN authentication.

Authentication methods for Source config

You can select either Kafka SSL Certificate or SASL Plain Credential as authentication method for your Kafka clusters.

Field Description Options

Credential type

Select an authentication method.

  1. Kafka SSL Certificate

Or

  1. SASL Plain Credential

Kafka SSL certificate

The Kafka SSL Credentials credential type requires the following parameters and certificates:

FieldRequiredDescriptionExample
Nameโœ…Identifier for the credentials. Used when accessing Sources.
Bootstrap serverโœ…The address of Kafka load balancer / Kafka cluster address.
CA certificateโœ…A certificate of Certificate authority (CA) in CRT format.
Client certificateโœ…Client SSL certificate in PEM format.
Client private keyโœ…Private keys of client certificate in PEM format.
Client private key passwordโœ…Password or passphrase of private keys for the client certificate.

You can either provide the certificates and client private key as plain text or upload the files.

Kafka SASL Plain Credential

The Kafka SASL Plain Credential credential type, which uses TLS/SSL as transport layer, requires the following parameters and certificates:

FieldRequiredDescription
Nameโœ…Identifier for the credentials. Used when accessing Sources.
Bootstrap serverโœ…The address of Kafka load balancer / Kafka cluster address.
Usernameโœ…Username for the SASL Plain Credential.
Passwordโœ…Password for the SASL Plain Credential.

Configuration parameters

Field Required Description

Name

โœ…

Identifier for the Source. Used when setting up Validators.

Cluster

โœ…

Name of the Kafka cluster to read data from.

Message format

โœ…

JSON, AVRO or PROTOBUF

Message schema

โœ…

JSON - Not needed, Validio automatically infers schema
AVRO - Refer to Avro Schema Declaration.
PROTOBUF - Refer to Protobuf Message Type.