chore(examples/recipes): Updating Kafka Example/Reciple (#3970)

examples/quick-start-go-and-kafka/.env.template

@@ -1,2 +1,4 @@
-TRACETEST_API_KEY="<YOUR_TRACETEST_API_KEY>"
-TRACETEST_API_TOKEN="<YOUR_TRACETEST_TOKEN>"
+# Get the required information here: https://app.tracetest.io/retrieve-token
+
+TRACETEST_TOKEN="<YOUR_TRACETEST_TOKEN>"
+TRACETEST_ENVIRONMENT_ID="<YOUR_ENV_ID>"

examples/quick-start-go-and-kafka/Dockerfile.tracetest

@@ -0,0 +1,11 @@
+FROM alpine
+
+WORKDIR /app
+ARG TRACETEST_IMAGE_VERSION=v1.4.0
+
+RUN apk --update add bash jq curl
+RUN curl -L https://raw.githubusercontent.com/kubeshop/tracetest/main/install-cli.sh | bash -s -- $TRACETEST_IMAGE_VERSION
+
+WORKDIR /resources
+
+ENTRYPOINT ["echo", "Tracetest CLI installed"]

examples/quick-start-go-and-kafka/tracetest/collector.config.yaml → examples/quick-start-go-and-kafka/collector.config.yaml

@@ -21,4 +21,4 @@ service:
     traces/1:
       receivers: [otlp]
       processors: [batch]
-      exporters: [otlp/jaeger]
+      exporters: [logging, otlp/jaeger]

examples/quick-start-go-and-kafka/docker-compose.yaml

@@ -61,20 +61,13 @@ services:
     ports:
       - 29092:29092
 
-  # Cloud-based Managed Tracetest
-  tracetest-agent:
-    image: kubeshop/tracetest-agent:latest
-    environment:
-      # Find the Agent API Key here: https://docs.tracetest.io/configuration/agent
-      - TRACETEST_API_KEY=${TRACETEST_API_KEY}
-
   otel-collector:
-    image: otel/opentelemetry-collector-contrib:0.59.0
+    image: otel/opentelemetry-collector-contrib:0.100.0
     command:
       - "--config"
       - "/otel-local-config.yaml"
     volumes:
-      - ./tracetest/collector.config.yaml:/otel-local-config.yaml
+      - ./collector.config.yaml:/otel-local-config.yaml
     ports:
       - 4317:4317
     depends_on:
@@ -94,3 +87,49 @@ services:
       interval: 1s
       timeout: 3s
       retries: 60
+
+  # Cloud-based Managed Tracetest
+  tracetest-agent:
+    image: kubeshop/tracetest-agent:latest
+    environment:
+      # Get the required information here: https://app.tracetest.io/retrieve-token
+      - TRACETEST_API_KEY=${TRACETEST_TOKEN}
+      - TRACETEST_ENVIRONMENT_ID=${TRACETEST_ENVIRONMENT_ID}
+
+  tracetest-apply:
+    build:
+      dockerfile: Dockerfile.tracetest
+    volumes:
+      - ./resources:/resources
+    environment:
+      TRACETEST_TOKEN: ${TRACETEST_TOKEN}
+      TRACETEST_ENVIRONMENT_ID: ${TRACETEST_ENVIRONMENT_ID}
+    entrypoint:
+      - bash
+      - /resources/apply.sh
+    networks:
+      default: null
+    depends_on:
+      producer-api:
+        condition: service_started
+      consumer-worker:
+        condition: service_started
+      tracetest-agent:
+        condition: service_started
+
+  tracetest-run:
+    build:
+      dockerfile: Dockerfile.tracetest
+    volumes:
+      - ./resources:/resources
+    environment:
+      TRACETEST_TOKEN: ${TRACETEST_TOKEN}
+      TRACETEST_ENVIRONMENT_ID: ${TRACETEST_ENVIRONMENT_ID}
+    entrypoint:
+      - bash
+      - /resources/run.sh
+    networks:
+      default: null
+    depends_on:
+      tracetest-apply:
+        condition: service_completed_successfully

examples/quick-start-go-and-kafka/resources/apply.sh

@@ -0,0 +1,17 @@
+#!/bin/sh
+
+set -e
+
+TOKEN=$TRACETEST_TOKEN
+ENVIRONMENT_ID=$TRACETEST_ENVIRONMENT_ID
+
+apply() {
+  echo "Configuring TraceTest"
+  tracetest configure --token $TOKEN --environment $ENVIRONMENT_ID
+
+  echo "Applying Resources"
+  tracetest apply datastore -f /resources/datastore.yaml
+  tracetest apply test -f /resources/test.yaml
+}
+
+apply

examples/quick-start-go-and-kafka/tracetest/tracetest-tracing-backend.yaml → examples/quick-start-go-and-kafka/resources/datastore.yaml

@@ -1,10 +1,12 @@
----
 type: DataStore
 spec:
-  name: Jaeger
+  id: current
+  name: jaeger
   type: jaeger
   default: true
   jaeger:
     endpoint: jaeger:16685
+    headers:
+      "": ""
     tls:
       insecure: true

examples/quick-start-go-and-kafka/resources/run.sh

@@ -0,0 +1,16 @@
+#!/bin/sh
+
+set -e
+
+TOKEN=$TRACETEST_TOKEN
+ENVIRONMENT_ID=$TRACETEST_ENVIRONMENT_ID
+
+run() {
+  echo "Configuring Tracetest"
+  tracetest configure --token $TOKEN --environment $ENVIRONMENT_ID
+
+  echo "Running Trace-Based Tests..."
+  tracetest run test -f /resources/test.yaml
+}
+
+run

examples/quick-start-go-and-kafka/test-consumer.yaml → examples/quick-start-go-and-kafka/resources/test.yaml

@@ -18,3 +18,4 @@ spec:
     name: It processed a message from Kafka
     assertions:
     - attr:tracetest.selected_spans.count = 1
+