feat: adds support for dockerfile, and docker-compose (#17)

* feat: adds initial version of async application using kafka

* chore: rename the directory

* feat: adds support for dockerfile, and docker-compose

* fix: fixed the resolution of env vars

* fix: adds network support for this

* fix: fix the generation of config.yaml file, URL expose

* feat: fixed the agent version which was causing http2 issue

Author: kotharironak

async-kafka-application/README.md

@@ -1,2 +1,9 @@
-## Sample application for aync trace
-- under developement
+## Sample application for async trace
+Build
+- run the command `./gradlew jar`
+- run the command to prepare docker file `docker build ./`
+
+Running
+- use docker-compose file provided in docker folder and run
+- change the ENV `TRACE_EXPORTER_END_POINT` for your appropriate endpoint
+- `docker-compose -f docker-compose.yaml up`

async-kafka-application/async-kafka-consumer/Dockerfile

@@ -0,0 +1,20 @@
+# ARG VERSION=1.0
+# ARG HYPERTRACE_AGENT_VERSION=1.0.5
+
+FROM openjdk:11.0.10-jdk-buster
+WORKDIR /app
+RUN wget https://github.com/hypertrace/javaagent/releases/download/1.0.5/hypertrace-agent-all.jar && ls .
+COPY build/libs libs/
+COPY build/resources resources/
+COPY config.yaml config.yaml
+COPY run.sh run.sh
+RUN chmod a+x run.sh
+
+ENV HT_CONFIG_FILE=config.yaml
+ENV SERVICE_NAME=async-kafka-consumer
+ENV KAFKA_BOOTSTRAP_SERVERS=localhost:9092
+ENV TRACE_EXPORTER_END_POINT=localhost:9411
+EXPOSE ${PORT}
+
+#ENTRYPOINT ["java", "-javaagent:/app/hypertrace-agent-all.jar", "-jar", "./libs/async-kafka-consumer-1.0.jar"]
+ENTRYPOINT ["./run.sh"]

async-kafka-application/async-kafka-consumer/config.yaml

@@ -1,3 +1,3 @@
 service_name: async-kafka-consumer
 reporting:
-  endpoint: http://localhost:9411/api/v2/spans
+  endpoint: http://host.docker.internal/api/v2/spans

async-kafka-application/async-kafka-consumer/run.sh

@@ -0,0 +1,14 @@
+#!/usr/bin/env bash
+set -eu
+ENDPOINT=${TRACE_EXPORTER_END_POINT:-"http://localhost:9411/api/v2/spans"}
+NAME=${SERVICE_NAME:-"async-kafka-consumer"}
+
+# prepare config.yaml file
+text=''
+text=$text"service_name: ${NAME}\n"
+text=$text"reporting:\n"
+text=$text"  endpoint: ${ENDPOINT}\n"
+echo -e $text > config.yaml
+
+java -javaagent:/app/hypertrace-agent-all.jar -jar /app/libs/async-kafka-consumer-1.0.jar
+

async-kafka-application/async-kafka-consumer/src/main/java/org/hypertrace/example/async/kafka/consumer/Entry.java

@@ -13,7 +13,7 @@ public class Entry {
 
   public static void main(String[] args) {
     try {
-      Config config = ConfigFactory.parseResources("application.conf");
+      Config config = ConfigFactory.parseResources("application.conf").resolve();
       String bootstrapServer = config.getString("kafka.bootstrap.server");
       String consumerTopic = config.getString("kafka.consumer.topic");
       int maxWaitTime = config.getInt("maxWaitTime");

async-kafka-application/async-kafka-consumer/src/main/resources/application.conf

@@ -1,5 +1,6 @@
 kafka {
   bootstrap.server="localhost:9092"
+  bootstrap.server = ${?KAFKA_BOOTSTRAP_SERVERS}
   consumer.topic="test-async-trace"
 }
 maxWaitTime=20

async-kafka-application/async-kafka-producer-httpservice/Dockerfile

@@ -0,0 +1,21 @@
+# ARG VERSION=1.0
+# ARG HYPERTRACE_AGENT_VERSION=1.0.5
+
+FROM openjdk:11.0.10-jdk-buster
+WORKDIR /app
+RUN wget https://github.com/hypertrace/javaagent/releases/download/1.0.5/hypertrace-agent-all.jar && ls .
+COPY build/libs libs/
+COPY build/resources resources/
+COPY config.yaml config.yaml
+COPY run.sh run.sh
+RUN chmod a+x run.sh
+
+ENV HT_CONFIG_FILE=config.yaml
+ENV SERVICE_NAME=async-kafka-producer-httpservice
+ENV KAFKA_BOOTSTRAP_SERVERS=localhost:9092
+ENV PORT=2020
+ENV TRACE_EXPORTER_END_POINT=localhost:9411
+
+EXPOSE ${PORT}
+#ENTRYPOINT ["java", "-javaagent:/app/hypertrace-agent-all.jar", "-jar", "./libs/async-kafka-producer-httpservice-1.0.jar"]
+ENTRYPOINT ["./run.sh"]

async-kafka-application/async-kafka-producer-httpservice/config.yaml

@@ -1,3 +1,3 @@
 service_name: async-kafka-producer-httpservice
 reporting:
-  endpoint: http://localhost:9411/api/v2/spans
+  endpoint: http://host.docker.internal:9411/api/v2/spans

async-kafka-application/async-kafka-producer-httpservice/run.sh

@@ -0,0 +1,13 @@
+#!/usr/bin/env bash
+set -eu
+ENDPOINT=${TRACE_EXPORTER_END_POINT:-"http://localhost:9411/api/v2/spans"}
+NAME=${SERVICE_NAME:-"async-kafka-producer-httpservice"}
+
+# prepare config.yaml file
+text=''
+text=$text"service_name: ${NAME}\n"
+text=$text"reporting:\n"
+text=$text"  endpoint: ${ENDPOINT}\n"
+echo -e $text > config.yaml
+
+java -javaagent:/app/hypertrace-agent-all.jar -jar ./libs/async-kafka-producer-httpservice-1.0.jar

async-kafka-application/async-kafka-producer-httpservice/src/main/java/org/hypertrace/example/async/kafka/producer/httpservice/Entry.java

@@ -12,7 +12,7 @@ public class Entry {
 
   public static void main(String[] args) {
     try {
-      Config config = ConfigFactory.parseResources("application.conf");
+      Config config = ConfigFactory.parseResources("application.conf").resolve();
       updateRuntime();
       server.init(config);
       server.start();