Commit 8387d16f authored by Lluis Gifre Renom's avatar Lluis Gifre Renom
Browse files

Kafka deployment: 

- Fix kafka service name
parent c2952cca

src/common/tools/kafka/Variables.py

+1 −1
Original line number Diff line number Diff line
@@ -19,7 +19,7 @@ from kafka.errors import TopicAlreadyExistsError 
from common.Settings import get_setting



LOGGER = logging.getLogger(__name__)

KFK_SERVER_ADDRESS_TEMPLATE = 'kafka-public.{:s}.svc.cluster.local:{:s}'

KFK_SERVER_ADDRESS_TEMPLATE = 'kafka-service.{:s}.svc.cluster.local:{:s}'



KAFKA_TOPIC_NUM_PARTITIONS         = 1

KAFKA_TOPIC_REPLICATION_FACTOR     = 1

src/policy/src/main/resources/application.yml

+1 −1
Original line number Diff line number Diff line
@@ -63,7 +63,7 @@ quarkus: 
        context-service-host: "contextservice"

        monitoring-service-host: "monitoringservice"

        service-service-host: "serviceservice"

        kafka-broker-host: "kafka-public.kafka.svc.cluster.local"

        kafka-broker-host: "kafka-service.kafka.svc.cluster.local"

    resources:

      requests:

        cpu: 50m

src/policy/target/kubernetes/kubernetes.yml

+1 −1
Original line number Diff line number Diff line
@@ -80,7 +80,7 @@ spec: 
            - name: MONITORING_SERVICE_HOST

              value: monitoringservice

            - name: KAFKA_BROKER_HOST

              value: kafka-public.kafka.svc.cluster.local

              value: kafka-service.kafka.svc.cluster.local

            - name: CONTEXT_SERVICE_HOST

              value: contextservice

          image: labs.etsi.org:5050/tfs/controller/policy:0.1.0

src/tests/ofc26_flexscale/run_ofc26_test.sh

+1 −1
Original line number Diff line number Diff line
@@ -23,7 +23,7 @@ export CRDB_URI="cockroachdb://tfs:tfs123@${CRDB_SQL_ADDRESS}:26257/tfs_kpi_mgmt 
#added for kafka exposure

export KFK_SERVER_ADDRESS='127.0.0.1:9094'



kubectl port-forward -n kafka service/kafka-public 9094:9094 > /dev/null 2>&1 &

kubectl port-forward -n kafka service/kafka-service 9094:9094 > /dev/null 2>&1 &

KAFKA_PF_PID=$!



# Function to cleanup port-forward on exit