fix: remove kafka client rename (#353)

* fixed config for central-ledger integration tests and added flag for db-int * updated dependencies and ignored vulnerabilities for a month * removed kafka client renaming and updated dependencies * added "allow.auto.create.topics" to rdkafka conf Co-authored-by: Shashikant Hirugade <shashi.pioneer@gmail.com>
mojaloop · May 27, 2021 · fbd6980 · fbd6980
1 parent 661f193
commit fbd6980
Show file tree

Hide file tree

Showing 10 changed files with 1,011 additions and 2,313 deletions.
diff --git a/config/default.json b/config/default.json
@@ -72,7 +72,8 @@
               "client.id": "cs-con-deferredsettlement-close",
               "group.id": "cs-group-deferredsettlement-close",
               "metadata.broker.list": "localhost:9092",
-              "socket.keepalive.enable": true
+              "socket.keepalive.enable": true,
+              "allow.auto.create.topics": true
             },
             "topicConf": {
               "auto.offset.reset": "earliest"
@@ -97,7 +98,8 @@
               "client.id": "cs-con-notification-event",
               "group.id": "cs-group-notification-event",
               "metadata.broker.list": "localhost:9092",
-              "socket.keepalive.enable": true
+              "socket.keepalive.enable": true,
+              "allow.auto.create.topics": true
             },
             "topicConf": {
               "auto.offset.reset": "earliest"

diff --git a/docker/central-ledger/default.json b/docker/central-ledger/default.json
@@ -118,7 +118,8 @@
               "client.id": "cl-con-bulk-prepare",
               "group.id": "cl-group-bulk-prepare",
               "metadata.broker.list": "kafka:9092",
-              "socket.keepalive.enable": true
+              "socket.keepalive.enable": true,
+              "allow.auto.create.topics": true
             },
             "topicConf": {
               "auto.offset.reset": "earliest"
@@ -141,7 +142,8 @@
               "client.id": "cl-con-bulk-processing",
               "group.id": "cl-group-bulk-processing",
               "metadata.broker.list": "kafka:9092",
-              "socket.keepalive.enable": true
+              "socket.keepalive.enable": true,
+              "allow.auto.create.topics": true
             },
             "topicConf": {
               "auto.offset.reset": "earliest"
@@ -164,7 +166,8 @@
               "client.id": "cl-con-bulk-fulfil",
               "group.id": "cl-group-bulk-fulfil",
               "metadata.broker.list": "kafka:9092",
-              "socket.keepalive.enable": true
+              "socket.keepalive.enable": true,
+              "allow.auto.create.topics": true
             },
             "topicConf": {
               "auto.offset.reset": "earliest"
@@ -187,7 +190,8 @@
               "client.id": "cl-con-bulk-get",
               "group.id": "cl-group-bulk-get",
               "metadata.broker.list": "kafka:9092",
-              "socket.keepalive.enable": true
+              "socket.keepalive.enable": true,
+              "allow.auto.create.topics": true
             },
             "topicConf": {
               "auto.offset.reset": "earliest"
@@ -212,7 +216,8 @@
               "client.id": "cl-con-transfer-prepare",
               "group.id": "cl-group-transfer-prepare",
               "metadata.broker.list": "kafka:9092",
-              "socket.keepalive.enable": true
+              "socket.keepalive.enable": true,
+              "allow.auto.create.topics": true
             },
             "topicConf": {
               "auto.offset.reset": "earliest"
@@ -235,7 +240,8 @@
               "client.id": "cl-con-transfer-get",
               "group.id": "cl-group-transfer-get",
               "metadata.broker.list": "kafka:9092",
-              "socket.keepalive.enable": true
+              "socket.keepalive.enable": true,
+              "allow.auto.create.topics": true
             },
             "topicConf": {
               "auto.offset.reset": "earliest"
@@ -258,7 +264,8 @@
               "client.id": "cl-con-transfer-fulfil",
               "group.id": "cl-group-transfer-fulfil",
               "metadata.broker.list": "kafka:9092",
-              "socket.keepalive.enable": true
+              "socket.keepalive.enable": true,
+              "allow.auto.create.topics": true
             },
             "topicConf": {
               "auto.offset.reset": "earliest"
@@ -281,7 +288,8 @@
               "client.id": "cl-con-transfer-position",
               "group.id": "cl-group-transfer-position",
               "metadata.broker.list": "kafka:9092",
-              "socket.keepalive.enable": true
+              "socket.keepalive.enable": true,
+              "allow.auto.create.topics": true
             },
             "topicConf": {
               "auto.offset.reset": "earliest"
@@ -306,7 +314,8 @@
               "client.id": "cl-con-transfer-admin",
               "group.id": "cl-group-transfer-admin",
               "metadata.broker.list": "kafka:9092",
-              "socket.keepalive.enable": true
+              "socket.keepalive.enable": true,
+              "allow.auto.create.topics": true
             },
             "topicConf": {
               "auto.offset.reset": "earliest"

diff --git a/docker/central-settlement/default.json b/docker/central-settlement/default.json
@@ -72,7 +72,8 @@
               "client.id": "cs-con-deferredsettlement-close",
               "group.id": "cs-group-deferredsettlement-close",
               "metadata.broker.list": "kafka:9092",
-              "socket.keepalive.enable": true
+              "socket.keepalive.enable": true,
+              "allow.auto.create.topics": true
             },
             "topicConf": {
               "auto.offset.reset": "earliest"
@@ -97,7 +98,8 @@
               "client.id": "cs-con-notification-event",
               "group.id": "cs-group-notification-event",
               "metadata.broker.list": "kafka:9092",
-              "socket.keepalive.enable": true
+              "socket.keepalive.enable": true,
+              "allow.auto.create.topics": true
             },
             "topicConf": {
               "auto.offset.reset": "earliest"