Install and Configure the Recipe

On your Oracle Integration instance, install the recipe to deploy and configure the integration and associated resources.

Install the recipe on your Oracle Integration instance. See Install a Recipe or Accelerator.

After you've installed the recipe, configure the following resources:

Configure the Apache Kafka Connection

  1. In the Connections section, click the connection name.
  2. In the Bootstrap Servers field, enter the Bootstrap Server URL you obtained earlier while configuring Apache Kafka. See Configure Apache Kafka.
  3. In the Security Policy field, select SASL PLAIN Over SSL.
  4. In the SASL Username and SASL Password fields, enter the Apache Kafka API Key and Secret that you obtained earlier while configuring Apache Kafka. See Configure Apache Kafka.
  5. Complete the following:
    1. Upload the truststore file in the TrustStore field.
    2. Upload the keystore file in the KeyStore field.
    3. Enter the truststore password in the Truststore password field.
    4. Enter the keystore passowrd in the KeyStore password field.
  6. Click Save. If prompted, click Save again.
  7. Click Test to ensure that your connection is successfully configured. In the resulting dialog, click Test again.

    A message confirms if your test is successful.

  8. To return to the project workspace, click Go back Back icon.

Configure the REST Amazon S3 Connection

  1. In the Connections section, click the connection name.
  2. In the Properties section, enter the following details:
    Field Information to Enter
    Connection Type

    Select REST API Base URL.

    Connection URL

    Enter https://s3.<your-bucket-region>.amazonaws.com/.

    Where your-bucket-region is the region in which you had set up your Amazon S3 bucket. For example, https://s3.eu-central-1.amazonaws.com/.

    See Configure Amazon S3.

  3. In the Security section, enter the following details:
    Field Information to Enter
    Security Policy Select AWS Signature Version 4.
    Access Key

    Enter the access key that you obtained.

    See Configure Amazon S3.

    Secret Key Enter the secret key that you obtained.
    AWS Region Select the AWS region where you have created the Amazon S3 bucket. For example, eu-central-1.
    Service Name Select Amazon Simple Storage Service (Amazon S3).
  4. Click Save. If prompted, click Save again.
  5. Click Test to ensure that your connection is successfully configured. In the resulting dialog, click Test again.

    A message confirms if your test is successful.

  6. To return to the project workspace, click Go back Back icon.

Configure the Integration Flow

Configure the Apache Kafka adapter endpoint properties in the integration.

  1. In the Integrations section, click the integration flow name.
  2. On the integration canvas, click the LoadTopicMessages element, and then click Actions Actions icon and select Edit.
    The Apache Kafka Endpoint Configuration Wizard with its Basic Info page is displayed.
  3. Click Next in the Basic Info page.
  4. In the Operation page that appears, click Next again.
    The Topic & Partition page is displayed.
  5. Configure the following in the Topic & Partition page.
    1. In the Select a Topic list, select the Apache Kafka topic from which you want to query and fetch messages.
    2. Select a partition from the Specify the Partition list, or use the Default selection.
    3. Specify the consumer group to use in the Consumer Group field.
    4. Select the Read latest option under Specify the option for consuming messages.
    5. In the Maximum Number of Records to be fetched field, specify the number of messages to be read.
    6. In the Do you want to specify the message structure? field, select No.
    7. In the Do you want to specify the headers for the message? field, select No.
    8. Click Next and then click Done.
    See Add the Kafka Adapter Connection to an Integration in Using the Apache Kafka Adapter with Oracle Integration 3.
  6. Click Save. If prompted, click Save again.
  7. To return to the project workspace, click Go back Back icon.