|
|
5 years ago | |
|---|---|---|
| .. | ||
| kafka-consumer | 5 years ago | |
| kafka-producer | 5 years ago | |
| resources | 5 years ago | |
| README.md | 5 years ago | |
| pom.xml | 5 years ago | |
README.md
Brief
Implement an automated OpenShift 4 solution that will include:
[X] Strimzi - meh, sort of, working with local strimzi [X] Quarkus Kafka producer application. This application should periodically send data (e.g. timestamp) to Kafka and should also have a JAX-RS endpoint to send different data per user request. - Done standalone [X] Quarkus Kafka consumer application. This application should present the data to a websocket. There should be a way for the user to display the data easily.
The solution should be comfortable to deploy, test, debug and use. The implementation time frame is one week. If you do not have an OCP4 cluster available, feel free to use CRC - https://developers.redhat.com/products/codeready-containers/overview
Strimzi
- Use ansible to install the Strimzi operator
- Use the operator to setup Kafka + namespaces etc
- Enable debugging + log aggregation where available
Quarkus Kafka producer application
- Timestamp generator (cron?/timer?)
- JAX-RS + swagger
- Debugging mode (maven profile)
Quarkus Kafka consumer application
- Websocket
- HTML+JS
- Debugging mode (maven profile)
For testing npm install wscat and then wscat -c http://localhost:8080/kafka/message/foo
Deploy to OCP -
mvn clean package -Dquarkus.container-image.build=true -Dquarkus.openshift.expose=true
mvn clean package -Dquarkus.kubernetes.deploy=true -Dquarkus.http.port=8080