Table of Contents

Search

  1. Preface
  2. Workflow Manager
  3. Workflows and Worklets
  4. Sessions
  5. Session Configuration Object
  6. Tasks
  7. Sources
  8. Targets
  9. Connection Objects
  10. Validation
  11. Scheduling and Running Workflows
  12. Sending Email
  13. Workflow Monitor
  14. Workflow Monitor Details
  15. Session and Workflow Logs
  16. Session Properties Reference
  17. Workflow Properties Reference

Workflow Basics Guide

Workflow Basics Guide

PowerExchange for Kafka Connections

PowerExchange for Kafka Connections

When you configure a Kafka connection, you define the connection attributes that the PowerCenter Integration Service uses to connect to the Kafka cluster.
The following table describes the Kafka connection properties:
Property
Description
Kafka Broker List
The IP address and port combinations of the Kafka messaging system broker list.
The IP address and port combination has the following format:
<IP Address>:<port>
You can enter multiple comma-separated IP address and port combinations.
Additional Connection Properties
Comma-separated list of connection properties to connect to the Kafka broker.
To connect to a Kafka broker over SSL, ensure that you set the following properties:
  • security.protocol
  • ssl.truststore.location
  • ssl.truststore.password
If the
ssl.client.auth
parameter is set to
required
or
requested
, ensure that you set the following properties:
  • ssl.keystore.location
  • ssl.keystore.password
  • ssl.key.password
For example,
security.protocol=SSL,ssl.truststore.location=<complete path and name of the client.truststore.jks file>,ssl.truststore.password=<client truststore password>,ssl.keystore.location=<complete path and name of the client.keystore.jks file>,ssl.keystore.password=<client keystore password>,ssl.key.password=<password for the individual key>
You can also specify the configuration properties required to connect to a Kerberised Kafka cluster.
Specify the following property:
security.protocol=SASL_PLAINTEXT,sasl.kerberos.service.name=kafka,sasl.mechanism=GSSAPI