Data Input Service is a microservice application designed to handle and publish real-time data streams efficiently.
Its primary role is to send and manage messages to an Apache Kafka server, functioning as a reliable producer service within a distributed system architecture.
Built using Java, Spring Boot, and Kafka, this service plays a key role in enabling event-driven communication and asynchronous data processing across multiple microservices.
The service exposes RESTful APIs to accept incoming data payloads, validate them, and forward them to designated Kafka topics.
It ensures reliable and scalable message delivery, making it a core component for systems that require real-time data streaming or event-driven workflows.
- Kafka Producer Integration – Publishes validated data messages to specific Kafka topics.
- RESTful APIs – Accepts incoming requests for message publishing.
- Scalable Architecture – Designed as a microservice for independent deployment and scaling.
- Spring Boot Configuration – Simplifies Kafka connection management and service setup.
- Error Handling & Logging – Includes structured error handling and logging for observability.
| Technology | Description |
|---|---|
| Java | Core language for business logic and message processing |
| Spring Boot | Framework for building and configuring the microservice |
| Apache Kafka | Distributed event streaming platform for message queuing |
| Maven | Dependency and build management tool |