From afdbf489b4d23812d48c35ba0f0bc3efa2aa2df4 Mon Sep 17 00:00:00 2001 From: Giselle van Dongen Date: Thu, 19 Dec 2024 09:19:04 +0100 Subject: [PATCH] Add Docker compose and restate.toml --- .../patterns-use-cases/docker-compose.yaml | 39 +++++++++++++++++++ .../patterns-use-cases/restate.toml | 3 ++ 2 files changed, 42 insertions(+) create mode 100644 java/patterns-use-cases/patterns-use-cases/docker-compose.yaml create mode 100644 java/patterns-use-cases/patterns-use-cases/restate.toml diff --git a/java/patterns-use-cases/patterns-use-cases/docker-compose.yaml b/java/patterns-use-cases/patterns-use-cases/docker-compose.yaml new file mode 100644 index 00000000..2e33e605 --- /dev/null +++ b/java/patterns-use-cases/patterns-use-cases/docker-compose.yaml @@ -0,0 +1,39 @@ +version: '3' +services: + broker: + image: confluentinc/cp-kafka:7.5.0 + container_name: broker + ports: + - "9092:9092" + - "9101:9101" + environment: + KAFKA_BROKER_ID: 1 + KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT + KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://broker:29092,PLAINTEXT_HOST://localhost:9092 + KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1 + KAFKA_GROUP_INITIAL_REBALANCE_DELAY_MS: 0 + KAFKA_TRANSACTION_STATE_LOG_MIN_ISR: 1 + KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR: 1 + KAFKA_PROCESS_ROLES: broker,controller + KAFKA_NODE_ID: 1 + KAFKA_CONTROLLER_QUORUM_VOTERS: 1@broker:29093 + KAFKA_LISTENERS: PLAINTEXT://broker:29092,CONTROLLER://broker:29093,PLAINTEXT_HOST://0.0.0.0:9092 + KAFKA_INTER_BROKER_LISTENER_NAME: PLAINTEXT + KAFKA_CONTROLLER_LISTENER_NAMES: CONTROLLER + KAFKA_LOG_DIRS: /tmp/kraft-combined-logs + CLUSTER_ID: MkU3OEVBNTcwNTJENDM2Qk + + init-kafka: + image: confluentinc/cp-kafka:7.5.0 + depends_on: + - broker + entrypoint: [ '/bin/sh', '-c' ] + command: | + "# blocks until kafka is reachable + kafka-topics --bootstrap-server broker:29092 --list + echo -e 'Creating kafka topics' + kafka-topics --bootstrap-server broker:29092 --create --if-not-exists --topic social-media-posts --replication-factor 1 --partitions 1 + kafka-topics --bootstrap-server broker:29092 --create --if-not-exists --topic package-location-updates --replication-factor 1 --partitions 1 + + echo -e 'Successfully created the following topics:' + kafka-topics --bootstrap-server broker:29092 --list" \ No newline at end of file diff --git a/java/patterns-use-cases/patterns-use-cases/restate.toml b/java/patterns-use-cases/patterns-use-cases/restate.toml new file mode 100644 index 00000000..8a0bde1c --- /dev/null +++ b/java/patterns-use-cases/patterns-use-cases/restate.toml @@ -0,0 +1,3 @@ +[[ingress.kafka-clusters]] +name = "my-cluster" +brokers = ["PLAINTEXT://localhost:9092"] \ No newline at end of file