9.2.28 Microsoft Fabric Eventstreams

This chapter describes how to use the Microsoft Fabric eventstreams.

• Overview
  
• Prerequisites
  

9.2.28.1 Overview

Microsoft Fabric eventstreams is a feature in Microsoft Fabric that captures, transforms, and routes real-time events to various destinations. You can add event data sources, destinations, and transformations to the eventstream.

Microsoft Fabric eventstreams enables event ingestion without writing custom code. You can create an eventstream, add event data sources, and route to supported destinations.

Microsoft Fabric eventstreams exposes a Kafka-compatible endpoint that allows the Oracle GoldenGate Replicat to publish change data capture (CDC) events using the standard Apache Kafka protocol. This enables Oracle GoldenGate to stream transactional changes from supported sources directly into Fabric real-time intelligence pipelines without custom code. Oracle GoldenGate uses the Kafka Handler to publish events to the Kafka endpoint exposed by Microsoft Fabric eventstreams.

9.2.28.2 Prerequisites

Before configuring Oracle GoldenGate for Microsoft Fabric evenstream:

1. Create a Microsoft Fabric eventstream with a custom endpoint source.
2. Retrieve the Kafka bootstrap servers, SASL credentials and Topic name from the custom endpoint (under SAS Key Authentication).
3. Ensure network accessibility from the GoldenGate deployment to the eventstream Kafka endpoint.
   Following is a sample producer.properties to consume from Microsoft Fabric eventstream:

   bootstrap.servers={YOUR_BOOTSTRAP_SERVERS}
   key.serializer=org.apache.kafka.common.serialization.StringDeserializer
   value.serializer=org.apache.kafka.common.serialization.StringDeserializer
   security.protocol=SASL_SSL
   sasl.mechanism=PLAIN
   sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="$ConnectionString" password="{YOUR_CONNECTION_STRING}";

   Note:

   Ensure credentials and bootstrap server settings are correctly fetched from the Microsoft Fabric eventstream UI or API.