How ujjal303/kafka-producer works
This Spring Boot service exposes HTTP endpoints for publishing messages and customer events to Kafka, and for deleting Kafka topics. Its producer also has an employee-event publishing method, though no sampled controller route invokes it. Kafka configuration declares the producer template, admin client, and two topics. The README is empty; the graph reflects the supplied source excerpts, so unsampled wiring is omitted.
Main entry points: KafkaConfig.java Kafka Configuration · KafkaAvroProducer.java Kafka Producer · EventController.java Event Controller · MessageBody.java Message Payload
Components 11
HTTP API
- Event Controller
src/main/java/com/ujjal/kafka/controller/EventController.java
Kafka Production
- Kafka Producer
src/main/java/com/ujjal/kafka/service/KafkaAvroProducer.java - Kafka Templates
src/main/java/com/ujjal/kafka/config/KafkaConfig.java - Admin Client
src/main/java/com/ujjal/kafka/config/KafkaConfig.java
Kafka Setup
- Kafka Configuration
src/main/java/com/ujjal/kafka/config/KafkaConfig.java
Event Models
- Message Payload
src/main/java/com/ujjal/kafka/models/MessageBody.java - Customer Detail
src/main/java/com/ujjal/kafka/models/CustomerDetail.java - Topic Request
src/main/java/com/ujjal/kafka/models/DeleteTopicsRequest.java - Employee Record
src/main/java/com/ujjal/kafka/models/Employee.java
Other components
- HTTP Client
- Kafka Broker
Connections 12
- HTTP Client → Event Controller: HTTP requests
- HTTP Client → Message Payload: sends payload
- HTTP Client → Customer Detail: sends payload
- HTTP Client → Topic Request: sends payload
- Event Controller → Kafka Producer: dispatches
- Kafka Producer → Kafka Templates: sends records
- Kafka Producer → Admin Client: deletes topics
- Kafka Configuration → Kafka Templates: creates
- Kafka Configuration → Admin Client: creates
- Kafka Configuration → Kafka Broker: declares topics
- Kafka Templates → Kafka Broker: publishes records
- Admin Client → Kafka Broker: deletes topics