Use the mqsisetdbparms command to associate security credentials with a connection to a Kafka cluster, and configure the KafkaProducer and KafkaConsumer nodes to authenticate using the required user ID and password.
Before you can connect to a Kafka cluster that requires authentication with a user ID and password, you must use the mqsisetdbparms command to configure the credentials that the KafkaProducer and KafkaConsumer nodes will use to authenticate to the Kafka cluster.
All Kafka nodes that are deployed to the same integration server must use the same set of credentials to authenticate to the Kafka cluster. To save the credentials that the Kafka nodes will use to connect to the Kafka cluster, you use the mqsisetdbparms command to configure the resource name in the form kafka::KAFKA::integrationServerName.
To configure the KafkaProducer or KafkaConsumer node to authenticate using the user ID and password, you set the Security protocol property on the node to either SASL_PLAINTEXT or SASL_SSL.
If you are using the IBM Event Streams service on IBM Cloud, the Security protocol property on the Kafka node must be set to SASL_SSL. For more information about configuring the security credentials for connecting to Event Streams, see Using Kafka nodes with IBM Event Streams.
Follow these steps to configure a connection to a secured Kafka cluster:
You can use the mqsireportdbparms command to show information about the credentials that are being used for connecting to a Kafka cluster. For more information about the security credentials that have been set on the integration node, see mqsireportdbparms command.