diff --git a/quarkus-kafaka-homework/docker-resources/docker-compose.yaml b/quarkus-kafaka-homework/docker-resources/docker-compose.yaml index d45bf58..159f91c 100644 --- a/quarkus-kafaka-homework/docker-resources/docker-compose.yaml +++ b/quarkus-kafaka-homework/docker-resources/docker-compose.yaml @@ -37,7 +37,7 @@ services: image: strimzi/kafka:0.11.3-kafka-2.1.0 command: [ "sh", "-c", - "bin/kafka-console-consumer.sh --bootstrap-server kafka:2091 --topic timestamp --topic user-message --from-beginning" + "bin/kafka-console-consumer.sh --bootstrap-server kafka:2091 --whitelist 'timestamp|user-message' --from-beginning" ] depends_on: - kafka diff --git a/quarkus-kafaka-homework/kafka-consumer/pom.xml b/quarkus-kafaka-homework/kafka-consumer/pom.xml index 9b41c26..5dd9658 100644 --- a/quarkus-kafaka-homework/kafka-consumer/pom.xml +++ b/quarkus-kafaka-homework/kafka-consumer/pom.xml @@ -1,11 +1,11 @@ - 4.0.0 - me.jochirst.kafka - kafka-parent - 1.0-SNAPSHOT + me.jochirst.kafka + kafka-parent + 1.0-SNAPSHOT kafka-consumer @@ -68,6 +68,10 @@ io.quarkus quarkus-smallrye-openapi + + io.quarkus + quarkus-container-image-jib + diff --git a/quarkus-kafaka-homework/kafka-consumer/src/main/resources/application.properties b/quarkus-kafaka-homework/kafka-consumer/src/main/resources/application.properties index d6acfce..9a302b3 100644 --- a/quarkus-kafaka-homework/kafka-consumer/src/main/resources/application.properties +++ b/quarkus-kafaka-homework/kafka-consumer/src/main/resources/application.properties @@ -6,6 +6,7 @@ kafka.bootstrap.servers=kafka-cluster-kafka-bootstrap:9092 %dev.kafka.bootstrap.servers=localhost:9092 %dev.quarkus.http.port=8081 quarkus.http.port=8080 + mp.messaging.incoming.user-message.connector=smallrye-kafka mp.messaging.incoming.user-message.topic=user-message mp.messaging.incoming.user-message.value.deserializer=org.apache.kafka.common.serialization.StringDeserializer diff --git a/quarkus-kafaka-homework/kafka-producer/pom.xml b/quarkus-kafaka-homework/kafka-producer/pom.xml index 0fe756f..02d6cac 100644 --- a/quarkus-kafaka-homework/kafka-producer/pom.xml +++ b/quarkus-kafaka-homework/kafka-producer/pom.xml @@ -63,7 +63,11 @@ io.quarkus quarkus-smallrye-openapi - + + io.quarkus + quarkus-container-image-jib + + diff --git a/quarkus-kafaka-homework/kafka-producer/src/main/resources/application.properties b/quarkus-kafaka-homework/kafka-producer/src/main/resources/application.properties index 792b898..54b7dcb 100644 --- a/quarkus-kafaka-homework/kafka-producer/src/main/resources/application.properties +++ b/quarkus-kafaka-homework/kafka-producer/src/main/resources/application.properties @@ -6,7 +6,7 @@ kafka.bootstrap.servers=kafka-cluster-kafka-bootstrap:9092 %dev.quarkus.http.port=8080 quarkus.http.port=8080 quarkus.swagger-ui.always-include=true - +quarkus.openshift.expose=true # Configure the Kafka sink (we write to it) mp.messaging.outgoing.timestamp.connector=smallrye-kafka diff --git a/quarkus-kafaka-homework/pom.xml b/quarkus-kafaka-homework/pom.xml index 94772fd..3bb268b 100644 --- a/quarkus-kafaka-homework/pom.xml +++ b/quarkus-kafaka-homework/pom.xml @@ -26,7 +26,8 @@ io.quarkus 1.8.1.Final 3.0.0-M5 - + s2i +