add kafka ui + minor fixes

docker/docker-compose.yml

@@ -85,3 +85,19 @@ services:
       chmod 600 /var/lib/pgadmin/storage/root_example.com/pgpass;
       /entrypoint.sh
       "
+      services:
+  kafka-ui:
+    container_name: kafka-ui
+    image: provectuslabs/kafka-ui:latest
+    ports:
+      - 8084:8080
+    depends_on:
+      - kafka
+    environment:
+      KAFKA_CLUSTERS_0_NAME: local
+      KAFKA_CLUSTERS_0_BOOTSTRAPSERVERS: kafka:29092
+      KAFKA_CLUSTERS_0_METRICS_PORT: 9997
+      KAFKA_CLUSTERS_0_SCHEMAREGISTRY: http://schemaregistry0:8085
+      KAFKA_CLUSTERS_0_KAFKACONNECT_0_NAME: first
+      KAFKA_CLUSTERS_0_KAFKACONNECT_0_ADDRESS: http://kafka-connect0:8083
+      DYNAMIC_CONFIG_ENABLED: "true"

packages/commons/src/logging/loggerMiddleware.ts

@@ -29,6 +29,7 @@ export const customFormat = winston.format.printf(
     const { userId, organizationId, correlationId } = getLoggerMetadata();
 
     const lines = message
+      .toString()
       .split("\n")
       .map(
         (line: string) =>

scripts/infra-start.sh

@@ -7,11 +7,11 @@ while [[ "$(curl -s -o /dev/null -w ''%{http_code}'' localhost:8083/connectors/)
   sleep 1
 done
 
-local URL="http://localhost:8083/connectors/"
+URL="http://localhost:8083/connectors/"
 
 # We need to wait until the service db to be available (whenever we stop getting 400 we know it's up)
 while true; do
-  local response=$(curl -s -o /dev/null -i -X POST -H "Accept:application/json" -H "Content-Type:application/json" -w "%{http_code}\n" -d "@register-connector-postgres.json" "$URL")
+  response=$(curl -s -o /dev/null -i -X POST -H "Accept:application/json" -H "Content-Type:application/json" -w "%{http_code}\n" -d "@register-connector-postgres.json" "$URL")
 
   if [ "$response" -eq "201" ]; then
     echo "Connector registered successfully"