This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/streampipes.git
The following commit(s) were added to refs/heads/dev by this push:
new b5c355d346 refactor(#3907): update docker-compose.yml to use nats
broker (#3908)
b5c355d346 is described below
commit b5c355d346d8ab697c553a07b6a283f9072067f1
Author: Philipp Zehnder <[email protected]>
AuthorDate: Thu Nov 13 13:41:20 2025 +0100
refactor(#3907): update docker-compose.yml to use nats broker (#3908)
---
.gitignore | 2 ++
.idea/icon.png | Bin 0 -> 5353 bytes
docker-compose.yml | 61 ++++++++++++++++++++++++++++++-----------------------
3 files changed, 37 insertions(+), 26 deletions(-)
diff --git a/.gitignore b/.gitignore
index 979496e559..7af5796846 100644
--- a/.gitignore
+++ b/.gitignore
@@ -32,6 +32,8 @@
.idea/uiDesigner.xml
.idea/*
+!.idea/icon.png
+
# Gradle:
.idea/gradle.xml
.idea/libraries
diff --git a/.idea/icon.png b/.idea/icon.png
new file mode 100644
index 0000000000..92f2f5adb2
Binary files /dev/null and b/.idea/icon.png differ
diff --git a/docker-compose.yml b/docker-compose.yml
index a8659193b1..80966ec5d4 100644
--- a/docker-compose.yml
+++ b/docker-compose.yml
@@ -34,6 +34,8 @@ services:
context: ./streampipes-service-core
dockerfile: Dockerfile
image: streampipes_backend:release-validation
+ environment:
+ - SP_PRIORITIZED_PROTOCOL=nats
depends_on:
- couchdb
volumes:
@@ -48,7 +50,7 @@ services:
dockerfile: Dockerfile
image: streampipes_ui:release-validation
environment:
- - SP_HTTP_SERVER_ADAPTER_ENDPOINT=extensions-all-jvm:8090
+ - SP_HTTP_SERVER_ADAPTER_ENDPOINT=extensions-all-iiot:8090
ports:
- "80:8088"
depends_on:
@@ -60,11 +62,11 @@ services:
networks:
spnet:
- extensions-all-jvm:
+ extensions-all-iiot:
build:
- context: ./streampipes-extensions/streampipes-extensions-all-jvm
+ context: ./streampipes-extensions/streampipes-extensions-all-iiot
dockerfile: Dockerfile
- image: streampipes_pipeline-elements-all-jvm:release-validation
+ image: streampipes_pipeline-elements-all-iiot:release-validation
logging: *default-logging
networks:
spnet:
@@ -80,28 +82,9 @@ services:
networks:
spnet:
- kafka:
- image: apache/kafka:4.1.0
- hostname: kafka
- environment:
- - KAFKA_NODE_ID=0
- - KAFKA_PROCESS_ROLES=controller,broker
- - KAFKA_AUTO_CREATE_TOPICS_ENABLE=true
- - KAFKA_CONTROLLER_QUORUM_VOTERS=0@kafka:9093
- - KAFKA_LISTENERS=PLAINTEXT://:9092,CONTROLLER://:9093,OUTSIDE://:9094
- -
KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://kafka:9092,OUTSIDE://localhost:9094
- -
KAFKA_LISTENER_SECURITY_PROTOCOL_MAP=CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT,OUTSIDE:PLAINTEXT
- - KAFKA_INTER_BROKER_LISTENER_NAME=PLAINTEXT
- - KAFKA_CONTROLLER_LISTENER_NAMES=CONTROLLER
- - KAFKA_MESSAGE_MAX_BYTES=5000012
- - KAFKA_REPLICA_FETCH_MAX_BYTES=10000000
- - KAFKA_FETCH_MESSAGE_MAX_BYTES=5000012
- - KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR=1
- - KAFKA_OFFSETS_TOPIC_NUM_PARTITIONS=1
- - KAFKA_DEFAULT_REPLICATION_FACTOR=1
- volumes:
- - kafka3:/var/lib/kafka/data
- logging: *default-logging
+ nats:
+ image: nats
+ restart: unless-stopped
networks:
spnet:
@@ -137,6 +120,32 @@ services:
networks:
spnet:
+ kafka:
+ image: apache/kafka:4.1.0
+ hostname: kafka
+ environment:
+ - KAFKA_NODE_ID=0
+ - KAFKA_PROCESS_ROLES=controller,broker
+ - KAFKA_AUTO_CREATE_TOPICS_ENABLE=true
+ - KAFKA_CONTROLLER_QUORUM_VOTERS=0@kafka:9093
+ - KAFKA_LISTENERS=PLAINTEXT://:9092,CONTROLLER://:9093,OUTSIDE://:9094
+ -
KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://kafka:9092,OUTSIDE://localhost:9094
+ -
KAFKA_LISTENER_SECURITY_PROTOCOL_MAP=CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT,OUTSIDE:PLAINTEXT
+ - KAFKA_INTER_BROKER_LISTENER_NAME=PLAINTEXT
+ - KAFKA_CONTROLLER_LISTENER_NAMES=CONTROLLER
+ - KAFKA_MESSAGE_MAX_BYTES=5000012
+ - KAFKA_REPLICA_FETCH_MAX_BYTES=10000000
+ - KAFKA_FETCH_MESSAGE_MAX_BYTES=5000012
+ - KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR=1
+ - KAFKA_OFFSETS_TOPIC_NUM_PARTITIONS=1
+ - KAFKA_DEFAULT_REPLICATION_FACTOR=1
+ volumes:
+ - kafka3:/var/lib/kafka/data
+ logging: *default-logging
+ networks:
+ spnet:
+
+
volumes:
kafka3:
couchdb:
