Kafka as a service for java, I wanted a way to easily implement the kafka producer and consumer to return it via a request and add this as portfolio filler/example.
I wanted to demonstrate specifically the following in a dynamic way for any kafka host/cluster:
Servlet->calls callable->kafka producer
Servlet->calls callable->kafka consumer
Currently Done
Used to demonstrate/test kafka hosts for APM (application performance monitoring) demonstrations to show tracing/examples to customers
Feel free to ping me on discord @probsJustin#6785 I dont plan to update this at this point in time but I guess I could help/build/run it if you have any questions but I reserve the right to tell you I don't have space/time to help.
Needs: Maven, docker, docker compose (included in docker in newer versions)
-
clone this repository......
-
go to kafka-docker directory
-
run the following comamnd:
docker-compose -f ./docker-compose-expose.yml up
- go to the base directory of this repository......
- run build.sh
- go to the following url:
http://localhost:8080/KAAS/kafkaConsumer?topic=topic_test&address=<YOUR LOCAL IP - TO ACCESS THE DOCKER CONTAINER>:9092
http://localhost:8080/KAAS/kafkaProducer?topic=topic_test&address=<YOUR LOCAL IP - TO ACCESS THE DOCKER CONTAINER>:9092&message=sure