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


Using Kafka nodes with IBM Message Hub

You can configure KafkaProducer and KafkaConsumer nodes to connect to the Message Hub service in IBM® Bluemix™.

Before you begin

Read the following topics:

About this task

IBM Message Hub for Bluemix 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 IBM Message Hub.

Before you can connect to IBM Message Hub, you must create a set of credentials in Message Hub, 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 Message Hub.

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 Message Hub:

  1. Create a set of credentials in IBM Message Hub, which the Kafka nodes will use for the connection.
  2. In IBM Message Hub, 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 Message Hub.

  3. Use the mqsisetdbparms command to associate the user name and password with the connection to Message Hub. 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 Message Hub.
    -u UserId
    The user ID to be used for connecting to Message Hub.
    -p Password
    The password to be used for connecting to Message Hub.
    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 Message Hub. For more information about the security credentials that have been set on the integration node, see mqsireportdbparms command.


bz91055_.htm | Last updated 2017-07-17 12:46:56