Checkpoint

buildSrc/build.gradle

@@ -8,4 +8,4 @@ repositories {
 
 dependencies {
     implementation "com.diffplug.spotless:spotless-plugin-gradle:6.25.0"
-}
+}

examples/docker/lightstreamer-kafka-stack.yaml

@@ -8,18 +8,21 @@ services:
     #   - kafka
     ports:
       - 8080:8080
-    networks:
-      - kafka-network
+    # networks:
+    #   - kafka-network
     volumes:
       - type: bind
-        source: deploy/connector
-        target: /lightstreamer/adapters/kafka-connector
-      - type: bind
-        source: deploy/conf/lightstreamer_conf.xml
-        target: /lightstreamer/conf/lightstreamer_conf.xml
+        source: build/install/lightstreamer-kafka-connector
+        target: /lightstreamer/adapters/lightstreamer-kafka-connector
+      # - type: bind
+      #   source: deploy/conf/lightstreamer_conf.xml
+      #   target: /lightstreamer/conf/lightstreamer_conf.xml
       - type: bind
         source: deploy/conf/lightstreamer_log_conf.xml
         target: /lightstreamer/conf/lightstreamer_log_conf.xml
+      - type: bind
+        source: secrets
+        target: /lightstreamer/adapters/lightstreamer-kafka-connector/secrets
 
   # kafka:
   #   image: 'docker.io/bitnami/kafka:latest'
@@ -38,5 +41,7 @@ services:
 
 networks:
   kafka-network:
+    name: lightstreamer-kafka-connector_default
+    # name: kafka-cluster-ssl_default
     external: true
-      # name: kafka-network
+

examples/quickstart/Dockerfile.kafka-connector

@@ -0,0 +1,11 @@
+FROM lightstreamer
+
+ARG version
+
+COPY deploy/lightstreamer-kafka-connector-${version}.zip /tmp/lightstreamer-kafka-connector.zip
+USER root
+RUN apt-get -y update; \
+    apt-get install -y unzip; \
+    unzip /tmp/lightstreamer-kafka-connector.zip -d /lightstreamer/adapters
+
+USER lightstreamer

examples/quickstart/Dockerfile.producer

@@ -0,0 +1,6 @@
+FROM eclipse-temurin:11
+ARG VERSION
+RUN mkdir /opt/producer
+
+COPY deploy/lightstreamer-kafka-connector-samples-all-0.1.0.jar  /opt/producer/lightstreamer-kafka-connector-samples-all.jar
+CMD ["java", "-jar", "/opt/producer/lightstreamer-kafka-connector-samples-all.jar"]

examples/quickstart/build.sh

@@ -0,0 +1,10 @@
+#!/bin/bash
+DEPLOY_DIR=$(pwd)/deploy
+rm -fr $DEPLOY_DIR || true
+mkdir $DEPLOY_DIR
+cd ../..
+./gradlew distribuite
+
+cp deploy/lightstreamer-kafka-connector-0.1.0.zip $DEPLOY_DIR
+cp deploy/lightstreamer-kafka-connector-samples-all-0.1.0.jar $DEPLOY_DIR
+docker compose -f examples/quickstart/docker-compose.yaml up --remove-orphans

examples/quickstart/docker-compose.yaml

@@ -0,0 +1,46 @@
+---
+version: '2'
+services:
+  lightstreamer:
+    build:
+      dockerfile: Dockerfile.kafka-connector
+      args:
+        version: 0.1.0
+      # context: ../../
+    # depends_on:
+    #   - broker
+    ports:
+      - 8080:8080
+
+  # producer:
+  #   build:
+  #     dockerfile: producer.Dockerfile
+  #     args:
+  #       VERSION: 0.1.0
+
+
+  # broker:
+  #   image: confluentinc/confluent-local:latest
+  #   ports:
+  #     - "9092:9092"
+  #     - "8082:8082"
+  #   environment:
+  #     KAFKA_NODE_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_SSL_KEYSTORE_LOCATION: /etc/kafka/secrets/kafka.server.keystore.jks
+  #     KAFKA_SSL_KEYSTORE_PASSWORD: password
+  #     KAFKA_PROCESS_ROLES: 'broker,controller'
+  #     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'
+  #     KAFKA_REST_HOST_NAME: rest-proxy
+  #     KAFKA_REST_BOOTSTRAP_SERVERS: 'broker:29092'
+  #     KAFKA_REST_LISTENERS: "http://0.0.0.0:8082"
+  #     CLUSTER_ID: '4L6g3nShT-eMCtK--X86sw'