updated all README.md

Author: quantdevv

polling-publisher/README.md

@@ -1,24 +1,24 @@
-# Polling Publisher-Subscriber System
+# Polling Publisher-Subscriber Microservice Pattern
 
 This project implements a **Polling Publisher-Subscriber** system using **Spring Boot** and **Apache Kafka**. It consists of two microservices:
 
-1. **Publisher Module** → Periodically polls a data source and publishes updates via Kafka.
-2. **Subscriber Module** → Listens to Kafka for updates and processes them.
+1. **Publisher Service** → Periodically polls a data source and publishes updates via Kafka.
+2. **Subscriber Service** → Listens to Kafka for updates and processes them.
 
 ## 📌 **Project Structure**
 ```
 polling-publisher-subscriber/
 │️— pom.xml  (Parent POM)
 │️— README.md  (This file)
 │
-├── publisher-module/
-│   ├── src/main/java/com/iluwatar/polling-service/
+├── polling-service/
+│   ├── src/main/java/com/iluwatar/polling/
 │   ├── src/main/resources/application.yml
 │   ├── pom.xml
 │   └── README.md  (Polling-specific documentation)
 │
-├── subscriber-module/
-│   ├── src/main/java/com/iluwatar/subscriber-service/
+├── subscriber-service/
+│   ├── src/main/java/com/iluwatar/subscriber/
 │   ├── src/main/resources/application.yml
 │   ├── pom.xml
 │   └── README.md  (Subscriber-specific documentation)
@@ -41,21 +41,7 @@ docker-compose up -d
 mvn clean install
 ```
 
-### 3️⃣ **Run the Publisher Module**
+### 3️⃣ **Run Service**
 ```sh
-mvn spring-boot:run -pl publisher-module
+mvn spring-boot:run
 ```
-
-### 4️⃣ **Run the Subscriber Module**
-```sh
-mvn spring-boot:run -pl subscriber-module
-```
-
-## 📝 **Endpoints**
-| Service | Endpoint | Description |
-|---------|----------|-------------|
-| Publisher | `GET /publish` | Manually trigger data publishing |
-| Subscriber | (Kafka Consumer) | Listens for updates |
-
-## 🛠 **Testing**
-You can test Kafka messages using:

polling-publisher/polling-service/README.md

@@ -2,7 +2,7 @@
 **README.md** (Inside `polling-module/`)
 
 
-## Publisher Module
+## Publisher Microservice
 
 This module is responsible for **polling a data source** at regular intervals and publishing updates to Kafka.
 
@@ -16,7 +16,12 @@ This module is responsible for **polling a data source** at regular intervals an
 ```
 publisher-module/
 │️— src/main/java/com/iluawatar/polling/
-|   ├── App.java
+|    ├── App.java
+│    ├── DataRepository.java
+│    ├── DataSourceService.java
+│    ├── KafkaProducer.java
+│    ├── PollingController.java
+│    └── PollingScheduler.java
 │
 │️— pom.xml
 │️— README.md  (This file)
@@ -29,8 +34,8 @@ mvn spring-boot:run
 ```
 
 ## 📝 **Endpoints**
-| Method | Endpoint | Description |
-|--------|----------|-------------|
-| `GET` | `/publish` | Manually trigger data publishing |
+| Method | Endpoint         | Description                      |
+|--------|------------------|----------------------------------|
+| `GET`  | `/health`        | check health of polling          |
+| `POST` | `/send?message=""` | Manually trigger data publishing |
 
-## 🛠 **Testing Kafka Output**

polling-publisher/subscriber-service/README.md

@@ -1,9 +1,9 @@
 # **Subscriber**
 README.md (Inside `subscriber-module/`)
 
-## Subscriber Module
+## Subscriber Microservice
 
-This module **listens** to Kafka topic **`updates_topic`** and processes updates.
+This module **listens** to Kafka topic **`updates & API`** and processes data.
 
 ## How It Works
 - Uses **Spring Kafka** to consume messages.
@@ -15,6 +15,7 @@ This module **listens** to Kafka topic **`updates_topic`** and processes updates
 subscriber-module/
 │➜ src/main/java/com/example/subscriber/
 |   ├── App.java
+|   |-- KafkaConsumer.java
 │
 │➜ pom.xml
 │➜ README.md  (This file)
@@ -25,14 +26,4 @@ subscriber-module/
 mvn spring-boot:run
 ```
 
-## Testing
-Verify subscriber output:
-```sh
-mvn spring-boot:run
-```
-Expected console output:
-```
-
-```
-
 ---