🚀 Kafka Clients App with Producer, Consumer, & RESTful API

Components

.
├── compose.yaml         (Provisions the Zookeeper and Kafka Broker)
├── domain-registration  (Mock: The Domain Registration REST Server)
├── enricher             (The App reading, processing, and writing to Kafka)
└── producer             (Mock: The Domain Classification Producer)

Usage

• Run the compose.yaml services to spin up Kafka broker,

 docker-compose up -d

• Start Domain Registration Service: AppServer.java (domain-registration/src/main/java/AppServer.java)
• Start Classification Decision Service: ProducerApp.java (producer/src/main/java/ProducerApp.java)
• Start Enrichment Service: qubits.EnricherApp.java (enricher/src/main/java/qubits/EnricherApp.java)
• To check the results, attach to the running Kafka container, and run the command, please consider removing the --from-beginning if only interested in the recent messages:

kafka-console-consumer \
  --bootstrap-server localhost:9092 \
  --topic enriched_classification_decisions \
  --from-beginning

• Failed messages should appear under the Dead-Letter Queue dlq_classification_decisions

kafka-console-consumer \
  --bootstrap-server localhost:9092 \
  --topic dlq_classification_decisions \
  --from-beginning

• To run tests, either from Intellij UI, or use the commands,

cd url-classifier-enrichment
./gradlew test