Integrating Solace with Microsoft Fabric

Businesses are constantly seeking ways to harness the power of real-time events in their advanced analytics platforms. This integration guide will walk you through the process of connecting Solace PubSub+ Platform, an event-driven integration and streaming platform, with Microsoft Fabric, an end-to-end data and analytics platform, using Solace’s built-in Kafka Bridge and the event streams feature (represented as an Eventstream item) in Fabric Real-Time Intelligence.

Why Integrate Fabric and Solace?

The combination of Solace’s robust event streaming capabilities and Microsoft Fabric’s comprehensive analytics toolset opens up new possibilities for organizations looking to:

• Streamline real-time data processing
• Enhance decision-making with up-to-the-minute insights
• Unify data streams across multi-cloud environments
• Scale analytics operations effortlessly
• Power AI workflows

By leveraging Solace’s Kafka Bridge and Fabric event streams feature, you can create a seamless pipeline that allows events from various sources to flow into Microsoft Fabric’s powerful platform.

In this guide, we’ll walk you step-by-step through the integration process, from setting up Solace PubSub+ Event Broker to configuring data flows in Microsoft Fabric Real-Time Intelligence. Whether you’re a data engineer, a solutions architect, or a business analyst, this tutorial will equip you with the knowledge to implement this powerful integration in your own environment.

Let’s dive in and unlock the potential of real-time event-driven analytics!

Key Technologies and Concepts

Solace PubSub+ Platform and Event-Driven Architecture

Solace PubSub+ Platform is an event-driven integration and streaming platform that lets you get data flowing between applications, devices, and people. You can use PubSub+ Platform to build an event mesh that allows events to flow dynamically across environments and around the world. This breaks down data silos and enables truly distributed event-driven systems. The platform’s built-in Kafka Bridge is a simple solution for integration with Kafka-based systems like Microsoft Fabric Eventstream.

Microsoft Fabric and Real-Time Intelligence Eventstream

Microsoft Fabric unifies various data analytics tools, providing a comprehensive suite for data storage, processing, and analysis. Within Fabric, event streams play a key role in real-time analytics, offering a scalable, Kafka-compatible interface for ingesting and processing streaming data.

Real-Time Intelligence is a powerful service that empowers everyone in your organization to extract insights and visualize their data in motion. It offers an end-to-end solution for event-driven scenarios, streaming data, and data logs. The event streams feature (represented as an Eventstream item) in Fabric Real-Time Intelligence allows you to gather real-time data from various sources, transform it, and route it to multiple destinations. It excels at handling large volumes of real-time data while providing advanced stream processing capabilities. Its tight integration with other Fabric services enables complex analytics workflows that combine real-time data with historical insights.

The combination of PubSub+ Platform and Microsoft Fabric’s event streams feature creates a powerful pipeline for real-time event streaming and analytics. This integration allows organizations to leverage Solace’s robust event management within Fabric’s rich analytics ecosystem, opening up new possibilities for immediate data-driven insights and decision-making.

The Integration Process

Prerequisites

Before beginning the integration process, ensure you have the following accounts set up:

1. Solace PubSub+ Account
   • An active Solace PubSub+ account
   • Active broker and permissions to manage Message VPNs and Bridges
   • A test non-exclusive queue, i.e. “hr/people/person/hired/v1″
2. Microsoft Power BI or Fabric Account
   • An active Power BI or Fabric account. If you don’t have one, start a free 30-day trial of Power BI Pro.
   • Access to Microsoft Fabric ‘https://app.fabric.microsoft.com/’ with your account. You can get a Microsoft Fabric subscription. Or, sign up for a free Microsoft Fabric trial.

These accounts are essential for accessing the necessary services and resources for the integration. We’ll cover additional requirements and configurations in the subsequent steps of the integration process.

Step 1: Configure Microsoft Fabric and an eventstream

In this step, we’ll set up Microsoft Fabric and configure an eventstream to receive data from a Solace event broker.

1. Access Microsoft Fabric:
   1. Log in to the Microsoft Fabric portal (https://app.fabric.microsoft.com)
   2.  Select ‘Real-Time Intelligence’ from the homepage after logging in.
2. Create a new Fabric workspace:
   1. Click “Create a workspace”.
   2. Provide a name for your workspace.
   3. Select ‘License mode’ in Advanced setting. You may select ‘Trial’ or ‘Fabric capacity’ with F8 SKU or ‘Premium capacity’ with P1 SKU if you have access to them.
   4. Click “Review + create”, then “Create”.
3. Set up an eventstream:
   1. Click “Create” in the left sidebar.
   2. Select “Eventstream” under “Real-Time Intelligence”.
   3.  Name your eventstream (e.g., “SolaceIntegrationStream”). To learn more, refer to Create an eventstream in Microsoft Fabric – Microsoft Fabric | Microsoft Learn
      
4. Select “Use Custom Endpoint”.
   
5. Name your custom endpoint (e.g. “Solace”) and click Add.
   
6. Publish the event stream.
   
7. Select the Source and In the bottom panel, select “Kafka”, then “Keys”.
   
8. Note the Bootstrap Server URL, Topic Name and “Connection String – Primary Key” for your broker configuration.
9. Click on “Sample code” and notice how it uses is “$ConnectionString” as the username and the connection string itself as the password. This will become important later!

Your Microsoft Fabric environment is now set up and ready to receive events from Solace. In the next step, we’ll connect Solace to Fabric using the Kafka Bridge.

Step 2: Set up Solace PubSub+ Kafka Bridge

In this step, we’ll guide you through the process of setting up a Solace PubSub+ Event Broker in your Solace Cloud account. This broker will serve as the foundation for our event-driven architecture.

1. Log in to your Solace Cloud account at https://console.solace.cloud/ or your dedicated SSO URL.
2. Access your broker:
   1. Select “Cluster Manager” and the broker you would like to configure.
   2. Select Connect in the top menu and choose any connection method. Note the username and password, you’ll need this to test later.
      
3. Select the Manage tab of our broker.
4. Select “Message VPN”.
5. Select “Bridges” in the left menu.
6. Click “Kafka Bridges” on the top menu and then “Kafka Senders”.
   IMAGE QUESTION
7. Select “+ Kafka Sender”.
   
8. Enable the Kafka Sender.
9. Enter the URL from your Eventstream source config.
10. Set Authentication Scheme to Basic.
11. Enter the username “$ConnectionString”. This is not a variable here, actually use this exact string for the username.
12. Enter the password, which was the value of Connection string-primary key in Fabric.
13. Save your new Kafka Sender!
14. Select Queue Bindings on the top menu of your new Bridge.
15. Select “+ Queue Binding”.
    
16. Select your Queue. (For testing purposes, make sure it is set to Non-Exclusive.)
17. Set Remote Topic to the Topic Name listed in the Kafka settings of your custom application in Fabric that you noted earlier.
    
18. On the summary tab, your Bridge should now be active with binded queues.
    

You are now ready to test the connectivity from end to end!

Step 3: Test the Connection

1. Use Solace’s Try-Me! feature to publish a test message to your Solace topic.
   1. Select Try Me on the left sidebar.
   2. Configure Try Me! Publisher.
      1. Keep the default URL but update port to 443 instead of 1443.
      2. Enter the broker username and password you noted earlier.
      3. Enter your test Queue, i.e. “hr/people/person/hired/v1″. This is bound to the remote topic you configured in the Queue Binding.
      4. Select Persistent.
   3. Configure Try Me! Subscriber
      1. Connect with same username and password.
      2. Subscribe to same queue.
   4. Enter a test JSON message in the Publisher and send. Make sure it is valid JSON, either an array of objects or line separated objects. Example: [{“name”:”John”, “age”:30, “car”:null}]
   5. Make sure your test message appears in the Try Me! Subscriber. Now let’s confirm it also made it’s way to Fabric!
2. Confirm receipt of the message in Fabric:
   1. In Fabric, select your eventstream.
   2. Select Data Preview and JSON.
   3. Your message should appear in Fabric:
      
   4. If you do not see your message, make sure your queue is non-exclusive, or close out the Try Me! test and try again. Also make sure your message is well-formed JSON, either!

Your event broker should now be connected to Microsoft Fabric via the Kafka Bridge. Events published to the configured Solace topics will flow into your Fabric event stream, ready for further processing and analysis.

Processing, Analyzing and Visualizing Solace Events with Microsoft Fabric Real-Time Intelligence

When integrating Solace with Microsoft Fabric, an eventhouse can be used to handle and analyze the large volumes of real-time event data coming from Solace. Eventhouses in Real-Time Intelligence are specifically designed to efficiently manage real-time data streams, allowing organizations to ingest, process, and analyze data in near real-time.

Let’s consider a situation where a company is using Solace to stream various types of event data, such as IoT sensor readings, application logs, and financial transactions. As these events flow into Fabric, an eventhouse can handle this diverse, time-based streaming data. Eventhouse excels at processing structured, semi-structured, and unstructured data, making it ideal for the varied event types typically seen in Solace implementations. The data is automatically indexed and partitioned based on ingestion time, facilitating efficient querying and analysis.

Within the eventhouse, you can create KQL (Kusto Query Language) databases to store and query your Solace event data. These databases provide an exploratory query environment for data exploration and management. You can enable data availability in OneLake at either the database or table level, allowing for flexible data storage options. The eventhouse also offers unified monitoring and management across all databases, providing insights such as compute usage, most active databases, and recent events. This capability is particularly valuable when dealing with multiple event streams from Solace, as it allows you to optimize performance and cost across your entire event processing pipeline.

You can export Kusto Query Language (KQL) queries to a Real-Time Dashboard in Real-Time Intelligence as visuals and modify their queries and formatting as needed. This integrated dashboard improves data exploration, query performance, and visualization.

Conclusion

Integrating Solace PubSub+ with Microsoft Fabric opens up powerful possibilities for real-time, event-driven data analytics. This guide has walked you through the key steps to establish this integration:

1. Set up a Solace PubSub+ Event Broker and a Kafka Bridge with a queue binding.
2. Configure Microsoft Fabric and an eventstream, preparing the environment to receive and process our event data.
3. Connect Solace to Microsoft Fabric using the Kafka Bridge, enabling event flow between the two platforms.

You also learned how you can analyze and manage the large volumes of real-time event data in a Fabric eventhouse.

By leveraging the strengths of  PubSub+ and Fabric, you can build scalable real-time data analytics solutions that can drive informed decision-making and enhance your organization’s agility in responding to events as they unfold.

Other Useful Resources

• Solace Kafka Bridging
• What is Real-Time Intelligence – Microsoft Fabric | Microsoft Learn
• Microsoft Fabric event streams overview – Microsoft Fabric | Microsoft Learn
• Eventhouse overview – Microsoft Fabric | Microsoft Learn