From 82e03978b89938219958032efb1448cc76baa181 Mon Sep 17 00:00:00 2001
From: Saumit <justsaumit@protonmail.com>
Date: Sat, 27 Sep 2025 02:14:26 +0530
Subject: Initial snapshot - OpenTelemetry demo 2.1.3 -f

---
 src/kafka/Dockerfile | 26 ++++++++++++++++++++++++++
 src/kafka/README.md  |  7 +++++++
 2 files changed, 33 insertions(+)
 create mode 100644 src/kafka/Dockerfile
 create mode 100644 src/kafka/README.md

(limited to 'src/kafka')

diff --git a/src/kafka/Dockerfile b/src/kafka/Dockerfile
new file mode 100644
index 0000000..8fd9c8c
--- /dev/null
+++ b/src/kafka/Dockerfile
@@ -0,0 +1,26 @@
+# Copyright The OpenTelemetry Authors
+# SPDX-License-Identifier: Apache-2.0
+
+
+FROM apache/kafka:3.9.1
+
+USER root
+ARG OTEL_JAVA_AGENT_VERSION
+
+USER appuser
+
+ADD --chown=appuser:appuser https://github.com/open-telemetry/opentelemetry-java-instrumentation/releases/download/v$OTEL_JAVA_AGENT_VERSION/opentelemetry-javaagent.jar /tmp/opentelemetry-javaagent.jar
+
+ENV KAFKA_CONTROLLER_LISTENER_NAMES=CONTROLLER
+ENV KAFKA_LISTENER_SECURITY_PROTOCOL_MAP=CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT
+ENV KAFKA_GROUP_INITIAL_REBALANCE_DELAY_MS=0
+ENV KAFKA_PROCESS_ROLES=controller,broker
+ENV KAFKA_NODE_ID=1
+ENV KAFKA_METADATA_LOG_SEGMENT_MS=15000
+ENV KAFKA_METADATA_MAX_RETENTION_MS=60000
+ENV KAFKA_METADATA_LOG_MAX_RECORD_BYTES_BETWEEN_SNAPSHOTS=2800
+ENV KAFKA_AUTO_CREATE_TOPICS_ENABLE=true
+ENV KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR=1
+ENV KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR=1
+ENV KAFKA_OPTS="-javaagent:/tmp/opentelemetry-javaagent.jar -Dotel.jmx.target.system=kafka-broker"
+ENV CLUSTER_ID=ckjPoprWQzOf0-FuNkGfFQ
diff --git a/src/kafka/README.md b/src/kafka/README.md
new file mode 100644
index 0000000..15d3d67
--- /dev/null
+++ b/src/kafka/README.md
@@ -0,0 +1,7 @@
+# Kafka
+
+This is used as a message queue service to connect the checkout service with
+the accounting and fraud detection services.
+
+Kafka is run in KRaft mode. Environment variables are substituted at
+deploy-time.
-- 
cgit v1.2.3