1. Using the Confluent Adapter with Oracle Integration 3
  2. Understand the Confluent Adapter
  3. Confluent Adapter Capabilities

Confluent Adapter Capabilities

The Confluent Adapter enables you to create an integration in Oracle Integration that connects to a Confluent messaging system. The Confluent Adapter connects to the Confluent distributed publish-subscribe messaging system from Oracle Integration and allows for the publishing and consumption of messages from a Confluent Kafka topic.

The Confluent Adapter provides the following capabilities:

  • Establishes a connection to the Confluent messaging system to enable messages to be published and consumed.
  • Consumes messages from a Confluent topic and produces messages to a Confluent topic in the invoke (outbound) direction.
  • Consumes messages from a topic based on a specified frequency in the trigger (inbound) direction.
  • Enables you to browse the available metadata using the Adapter Endpoint Configuration Wizard (that is, the topics and partitions to which messages are published and consumed).
  • Reads data from topics in the Kafka cluster using the Apache Kafka Streaming API.
  • Supports a consumer group.
  • Supports headers.
  • Supports the following message structures:
    • Avro schema document
    • XML schema (XSD) and schema archive upload
    • Sample XML

      These schemas are applicable for the following scenarios:

      • Producing and consuming messages - Invoke connections (supported with the connectivity agent only)
      • Consuming messages - Trigger connections (supported with the connectivity agent only)
  • Works only with the connectivity agent. Direct connectivity and connectivity to private endpoints is not supported.
  • Supports the following security policies:
    • SASL Plain over SSL
    • SASL Plain
  • Supports connectivity to a Confluent messaging system over SSL through the connectivity agent.
  • Supports optionally configuring the Confluent Kafka producer to be transactional. This enables an application to send messages to multiple partitions atomically.

You can configure the Confluent Adapter as an invoke connection in an integration in Oracle Integration. The Confluent Adapter is one of many predefined adapters included with Oracle Integration. See the Adapters page in the Oracle Help Center.