From 315f5cdea108455180cf9bcdff56d0a17cd558e8 Mon Sep 17 00:00:00 2001 From: Hasan Shahriar <7091945+hsleonis@users.noreply.github.com> Date: Fri, 1 Dec 2023 20:42:06 +0100 Subject: [PATCH] Update README.md --- README.md | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/README.md b/README.md index 0c662bf..5a6d966 100644 --- a/README.md +++ b/README.md @@ -1,8 +1,18 @@ # Real-time Weather Reporting App Real-time weather data from Accuweather APIs using Kafka + Streamlit dashboards. +**A simple Python app to display the workflows of Kafka with easy-to-use Streamlit UI.** + +**Kafka** is a distributed publish-subscribe messaging system that maintains feeds of messages in partitioned and replicated topics. In the simplest way there are three players in the Kafka ecosystem: producers, topics (run by brokers) and consumers. + +**Producers** produce messages to a topic. It is possible to attach a key to each message, in which case the producer guarantees that all messages with the same key will arrive to the same partition. **Topics** are logs that receive data from the producers and store them across their partitions. Producers always write new messages at the end of the log. In our example we made abstraction of the partitions, since we’re working locally. + +**Consumers** read the messages of a set of partitions of a topic of their choice at their own pace. If the consumer is part of a consumer group, i.e. a group of consumers subscribed to the same topic, they can commit their offset. This can be important if a topic is needed to consume in parallel with different consumers. + ## Producer Dashboard +The producer dashboard takes a location name as input, searches **Accuweather API** and receives current Weather data from it's APIs. Then, the **Kafka Producer** publises the Weather data to a Kafka topic. ## Consumer Dashboard +The consumer receives the published Weather data from the same Kafka topic and displayes in the consumer dashboard.