IBM Integration Bus, Version 10.0.0.17 Operating Systems: AIX, HP-Itanium, Linux, Solaris, Windows, z/OS


Using Kafka nodes with IBM Event Streams

You can configure KafkaProducer and KafkaConsumer nodes to connect to the Event Streams service in IBM® Cloud.

Before you begin

Read the following topics:

About this task

IBM Event Streams for IBM Cloud is a scalable, distributed, high-throughput message bus, which supports a number of client protocols including Kafka. You can use the KafkaProducer and KafkaConsumer nodes in IBM Integration Bus to receive messages from and send messages to Event Streams.

Before you can connect to Event Streams, you must create a set of credentials in Event Streams, which the IBM Integration Bus Kafka nodes will use to make a connection. You then can then use the mqsisetdbparms command to configure the credentials that the KafkaProducer and KafkaConsumer nodes will use to authenticate to Event Streams.

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 SASL_SSL.

For more information about configuring the security credentials for connecting to Kafka clusters, see Configuring security credentials for connecting to Kafka

Procedure

Follow these steps to configure a connection to IBM Event Streams:

  1. Create a set of credentials in Event Streams, which the Kafka nodes will use for the connection.
  2. In Event Streams, view the credentials and make a note of the list of servers in the kafka_brokers_sasl property. You will use this list of servers to populate the Bootstrap servers property on the KafkaConsumer and KafkaProducer nodes when you are creating your message flow.

    You will use the values in the User and Password fields to configure the security credentials that IBM Integration Bus will use to connect to Event Streams.

  3. Use the mqsisetdbparms command to associate the user name and password with the connection to Event Streams. You can specify the security credentials by setting the following parameters:
    -n kafka::KAFKA::integrationServerName
    The name of the security identity that is used to authenticate a connection to Event Streams.
    -u UserId
    The user ID to be used for connecting to Event Streams.
    -p Password
    The password to be used for connecting to Event Streams.
    The following example shows how to specify a user ID and password:
    mqsisetdbparms integrationNodeName -n kafka::KAFKA::integrationServerName -u myUsername -p myPassword

    For more information about associating security credentials with resources, see mqsisetdbparms command.

  4. On the Security tab of the KafkaProducer and KafkaConsumer nodes, set the Security protocol property to SASL_SSL, and set the SSL protocol property to TLSv1.2.

What to do next

You can use the mqsireportdbparms command to show information about the credentials that are being used for connecting to Event Streams. For more information about the security credentials that have been set on the integration node, see mqsireportdbparms command.


bz91055_.htm | Last updated 2019-07-13 08:14:07