Skip to content
#

kafka-topic

Here are 173 public repositories matching this topic...

RealTimeIncrementalSync is a real-time data streaming system that fetches product updates from a MySQL database, serializes the data in Avro format, and streams it to Kafka. Kafka consumers deserialize the data and append it to JSON files, enabling real-time monitoring and analysis of product information.

  • Updated Dec 24, 2024
  • Python

A scalable architecture for real-time log processing and visualization. Built with a Kafka-Spark ETL pipeline, DynamoDB for storing aggregate real-time metrics, and Python Dash for interactive dashboards. Designed for high-throughput log ingestion, real-time monitoring, and long-term storage.

  • Updated Dec 24, 2024
  • Python

All the resources you need to implement a functional simple architecture with an Accounts and an Email services using AsyncAPI, Anypoint Code Builder, and the available message brokers: Anypoint MQ, Kafka, Solace PubSub+, and Salesforce CDC/Platform Events

  • Updated Nov 19, 2024

Improve this page

Add a description, image, and links to the kafka-topic topic page so that developers can more easily learn about it.

Curate this topic

Add this topic to your repo

To associate your repository with the kafka-topic topic, visit your repo's landing page and select "manage topics."

Learn more