Browse Source

Openshift working, needed to enable route creation and also purged all

old DCs Routes Services etc
master
Jonathan Christison 5 years ago
parent
commit
fec75f3cc7
  1. 2
      quarkus-kafaka-homework/docker-resources/docker-compose.yaml
  2. 12
      quarkus-kafaka-homework/kafka-consumer/pom.xml
  3. 1
      quarkus-kafaka-homework/kafka-consumer/src/main/resources/application.properties
  4. 6
      quarkus-kafaka-homework/kafka-producer/pom.xml
  5. 2
      quarkus-kafaka-homework/kafka-producer/src/main/resources/application.properties
  6. 3
      quarkus-kafaka-homework/pom.xml

2
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

12
quarkus-kafaka-homework/kafka-consumer/pom.xml

@ -1,11 +1,11 @@
<?xml version="1.0"?>
<project xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" xmlns="http://maven.apache.org/POM/4.0.0"
<project xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd" xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>me.jochirst.kafka</groupId>
<artifactId>kafka-parent</artifactId>
<version>1.0-SNAPSHOT</version>
<groupId>me.jochirst.kafka</groupId>
<artifactId>kafka-parent</artifactId>
<version>1.0-SNAPSHOT</version>
</parent>
<artifactId>kafka-consumer</artifactId>
<properties>
@ -68,6 +68,10 @@
<groupId>io.quarkus</groupId>
<artifactId>quarkus-smallrye-openapi</artifactId>
</dependency>
<dependency>
<groupId>io.quarkus</groupId>
<artifactId>quarkus-container-image-jib</artifactId>
</dependency>
</dependencies>
<build>
<plugins>

1
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

6
quarkus-kafaka-homework/kafka-producer/pom.xml

@ -63,7 +63,11 @@
<groupId>io.quarkus</groupId>
<artifactId>quarkus-smallrye-openapi</artifactId>
</dependency>
</dependencies>
<dependency>
<groupId>io.quarkus</groupId>
<artifactId>quarkus-container-image-jib</artifactId>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>

2
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

3
quarkus-kafaka-homework/pom.xml

@ -26,7 +26,8 @@
<quarkus.platform.group-id>io.quarkus</quarkus.platform.group-id>
<quarkus.platform.version>1.8.1.Final</quarkus.platform.version>
<surefire-plugin.version>3.0.0-M5</surefire-plugin.version>
</properties>
<quarkus.container-image.builder>s2i</quarkus.container-image.builder>
</properties>
<!--
For kafka deployments lets skip 'em as default

Loading…
Cancel
Save