A bunch of stuff to learn quarkus
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
 
 
Jonathan Christison 6fe78f815c Add in memory messaging test and test basic user-message and timestamp 5 years ago
..
kafka-consumer Not really cleanup 5 years ago
kafka-producer Add in memory messaging test and test basic user-message and timestamp 5 years ago
resources Try docker container test instead of inmemory 5 years ago
README.md Add WIP profile to enable remote-debug on containers deployed to 5 years ago
pom.xml Try docker container test instead of inmemory 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