Commit 81d8c3a9 authored by Lluis Gifre Renom's avatar Lluis Gifre Renom
Browse files

Kafka deployment:

- Fix kafka service port
parent 8387d16f
Loading
Loading
Loading
Loading
+1 −1
Original line number Diff line number Diff line
@@ -83,7 +83,7 @@ spec:
          - name: KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAP
            value: "PLAINTEXT:PLAINTEXT,CONTROLLER:PLAINTEXT,EXTERNAL:PLAINTEXT"
          - name: KAFKA_CFG_ADVERTISED_LISTENERS
            value: "PLAINTEXT://kafka-service.kafka.svc.cluster.local:9092,EXTERNAL://localhost:9094"
            value: "PLAINTEXT://kafka-service.kafka.svc.cluster.local:9092,EXTERNAL://localhost:9092" # local clients use kubectl port-forward ... 9092:external
          - name: KAFKA_CFG_CONTROLLER_LISTENER_NAMES
            value: "CONTROLLER"
          - name: KAFKA_CFG_CONTROLLER_QUORUM_VOTERS
+2 −2
Original line number Diff line number Diff line
@@ -19,7 +19,7 @@ PROJECTDIR=`pwd`
cd $PROJECTDIR/src
RCFILE=$PROJECTDIR/coverage/.coveragerc

export KFK_SERVER_ADDRESS='127.0.0.1:9094'
export KFK_SERVER_ADDRESS='127.0.0.1:9092'

CRDB_SQL_ADDRESS=$(kubectl get service cockroachdb-public --namespace crdb -o jsonpath='{.spec.clusterIP}')
export CRDB_URI="cockroachdb://tfs:tfs123@${CRDB_SQL_ADDRESS}:26257/tfs_analytics?sslmode=require"
+1 −1
Original line number Diff line number Diff line
@@ -19,7 +19,7 @@ PROJECTDIR=`pwd`
cd $PROJECTDIR/src
RCFILE=$PROJECTDIR/coverage/.coveragerc

export KFK_SERVER_ADDRESS='127.0.0.1:9094'
export KFK_SERVER_ADDRESS='127.0.0.1:9092'
CRDB_SQL_ADDRESS=$(kubectl get service cockroachdb-public --namespace crdb -o jsonpath='{.spec.clusterIP}')
export CRDB_URI="cockroachdb://tfs:tfs123@${CRDB_SQL_ADDRESS}:26257/tfs_analytics?sslmode=require"

+1 −1
Original line number Diff line number Diff line
@@ -17,7 +17,7 @@ PROJECTDIR=`pwd`
cd $PROJECTDIR/src
RCFILE=$PROJECTDIR/coverage/.coveragerc

export KFK_SERVER_ADDRESS='127.0.0.1:9094'
export KFK_SERVER_ADDRESS='127.0.0.1:9092'

# This is unit test (should be tested with container-lab running)
python3 -m pytest --log-level=info --log-cli-level=info --verbose \
+1 −1
Original line number Diff line number Diff line
@@ -164,7 +164,7 @@ def telemetry_backend_service():
        # + Uncomment test_add_to_topology() in helper methods section to add a device.
    # - A KPI Descriptor must be added in KPI DB with correct device_id.
        # + Uncomment test_SetKpiDescriptor() in helper methods section to add a KPI Descriptor.
    # - Kafka should be exposed externally 'kubectl port-forward -n kafka service/kafka-service 9094:9094'.
    # - Kafka should be exposed externally 'kubectl port-forward -n kafka service/kafka-service 9092:9092'.
 
def test_helper_get_collector_by_kpi_id(kpi_manager_client, context_client):
    LOGGER.info("Testing get_collector_by_kpi_id...")
Loading