Skip to main content

How to generate a flow of events and publish to Confluent Cloud?

· 2 min read
Sergi Kedrov

How to generate a flow of events having a timestamp, a random {key, value} pair and publish to Confluent Cloud? With no line of code. For free.

Let's repeat the excercise from the previous post. We'll generate a flow of events having a timestamp, a random {key, value} pair and publish to Confluent Cloud. The only difference is that we've to substitute the AWS SQS Write Node by the Confluent Write Node. With no line of code.

Why Nodes?​

Why not! It's simple, fast, intuitive, equally understandable by people with different background.

Look at the picture above.

The "Generate -> ts, key, value" Actor employs the "Timer" Node to emitt events every 1 second. The frequency can be changed.

The "Timer" Node triggers the "Random" Node to generate random String and Integer values.

The values of the generated Timestamp, String and Integer are sent to the output "JSONout" and "Confluent Write" Nodes.

The "JSONout" Node composes JSON messages and produces results to the output "Confluent {ts, key, value}" Topic.

The "Confluent Write" Node composes JSON messages and publishes messages to the specified Topic at Confluent Cloud.

Watch the live flow of messages.

That's all. All you need to get started is to create or get access to your Confluen Cloud Control Plane and get credentials.

Try Nodes!​

  • Welcome to Fabrique.ai
  • Register to the Fabrique Node Editor. It’s for free
  • Find the “Generate → ts, key, value to Confluent” Project in Public projects
  • Duplicate the project to User Projects
  • Follow the instructions to configure AWS SQS credentials
  • Emulate adn deploy the project. Enjoy!
  • Find more Public projects to try
  • Read out Blog posts with more cases
  • Join our groups in LinkedIn, WhatsApp, Telegram, Slack
  • Ask your questions in Comments
  • Propose your case

About​

Fabrique is a no code service to zero the gap between real-time events and data-driven decisions.

Fabrique Nodes are created to give engineers, analysts and business people an intuitive and equally understandable language to easily prototype, deploy, run, and maintain complex event processing scenarios.

Welcome to Fabrique!