Kafka Client Configuration Details

To establish the connection successfully, you must have configured the Apache Kafka instance.

The Apache Kafka Client Configuration dialog box contains the following fields:
Condition Applicable Field Description
N/A Connection Name The unique name for the connection you are creating.

This name is displayed in the Connection drop-down list for all the TIBCO Flogo® Connector for Apache Kafka activities.

N/A Description A short description of the connection
N/A Brokers A comma-separated list of host and port pair (host:port) for establishing the initial connection with the Kafka cluster.
N/A Auth Mode Select one for following authentication type to establish the connection with Kafka cluster:
  • None: To establish the connection without authentication
  • SASL/PLAIN: To use Simple Authentication Security Layer (SASL) PLAIN authentication
  • SSL: To use Secure Socket Layer (SSL) authentication
Applicable only when SASL/PLAIN is selected in the Auth Mode field. User Name The user name for authentication.
Password The password for authentication.
Security Protocol

Select one of the following security protocols:

  • SASL_PLAINTEXT: Insecure connection to the broker
  • SASL_SSL: Default. Secure connection to the broker
Applicable only when SASL/PLAIN or SSL is selected in the Auth Mode field. Client Certificate A Privacy Enhanced Mail (PEM) encoded client certificate file for mutual authentication.
Client Key A PEM encoded private key file for mutual authentication.
CA or Server Certificate A PEM encoded private key file for server authentication.
N/A Connection Timeout The amount of time in seconds to wait for the initial connection.

Default value: 30 seconds

N/A Retry Backoff The amount of time in milliseconds to wait for leader election to occur before retrying.

Default value: 250 milliseconds

N/A Max Retry The number of attempts to retry metadata request when the cluster is in the middle of a leader election.

Default value: 3 attempts

N/A Refresh Frequency The amount of time in seconds after which metadata is refreshed.

Default value: 40 seconds

N/A Use Schema Registry

Enables you to use the Avro schema with a schema registry by selecting True.

If you select True, you must specify a Schema Registry URL. You can use the Confluent schema registry or the TIBCO schema registry. Depending on which schema registry you want to use, the Schema Registry URL need to be changed. Basic authentication is used to connect to the registry if a Username and Password are provided.

Note:
  • If True is selected, the schema displayed in the Schema for Avro Value field in the following tabs is read-only. If False is selected, you can create or modify the schema in both these tabs.
    • Input Settings tab of Kafka Producer
    • Output Settings tab of Kafka Consumer Trigger
  • SSL authentication is not supported.
Default value: False
Applicable only when True is selected in the Use Schema Registry field. Schema Registry URL The URL used to connect to a schema registry.

For the Confluent schema registry, the URL must be in the following format: 

http://<host>:<port>

For the TIBCO schema registry, the URL must be in the following format: 

http://<host>:<port>/schema/v1

Note: For TIBCO Schema Registry use the FTL realm URL.
Username (Optional) The username to access the schema registry with basic authentication.
Password (Optional) The password to access the schema registry with basic authentication.