Robin Moffatt 3/19/2021

Using ksqlDB to process data ingested from ActiveMQ with Kafka Connect

Read Original

This article details a solution for processing batched JSON data from ActiveMQ using Kafka Connect and ksqlDB. It explains the challenge of handling nested JSON arrays within an ActiveMQ message envelope and provides a step-by-step approach using Avro serialization and ksqlDB's EXPLODE function to split the array into individual Kafka messages.

Using ksqlDB to process data ingested from ActiveMQ with Kafka Connect

Comments

No comments yet

Be the first to share your thoughts!

Browser Extension

Get instant access to AllDevBlogs from your browser

Top of the Week