Update Kafka client for TLS config bugfix (#2688)

* Update Kafka client for TLS config bugfix * Set Kafka to be the default replication method until RPC replication stack is ready
cadence-workflow · Oct 18, 2019 · ecdaf96 · ecdaf96
1 parent 97284b5
commit ecdaf96
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 5 deletions.
diff --git a/config/development_active.yaml b/config/development_active.yaml
@@ -68,7 +68,7 @@ services:
 clusterMetadata:
   enableGlobalDomain: true
   replicationConsumer:
-    type: rpc
+    type: kafka
     fetcher:
       rpcParallelism: 1
       aggregationIntervalSecs: 2

diff --git a/config/development_standby.yaml b/config/development_standby.yaml
@@ -68,7 +68,7 @@ services:
 clusterMetadata:
   enableGlobalDomain: true
   replicationConsumer:
-    type: rpc
+    type: kafka
     fetcher:
       rpcParallelism: 1
       aggregationIntervalSecs: 2

diff --git a/go.mod b/go.mod
@@ -66,7 +66,7 @@ require (
 	github.com/stretchr/testify v1.3.0
 	github.com/uber-common/bark v1.2.1 // indirect
 	github.com/uber-go/atomic v1.4.0 // indirect
-	github.com/uber-go/kafka-client v0.2.2
+	github.com/uber-go/kafka-client v0.2.3-0.20191018205945-8b3555b395f9
 	github.com/uber-go/mapdecode v1.0.0 // indirect
 	github.com/uber-go/tally v3.3.11+incompatible
 	github.com/uber/jaeger-client-go v2.15.0+incompatible // indirect

diff --git a/go.sum b/go.sum
@@ -217,8 +217,8 @@ github.com/uber-common/bark v1.2.1 h1:cREJ9b7CpTjwZr0/5wV82fXlitoCIEHHnt9WkQ4lIk
 github.com/uber-common/bark v1.2.1/go.mod h1:g0ZuPcD7XiExKHynr93Q742G/sbrdVQkghrqLGOoFuY=
 github.com/uber-go/atomic v1.4.0 h1:yOuPqEq4ovnhEjpHmfFwsqBXDYbQeT6Nb0bwD6XnD5o=
 github.com/uber-go/atomic v1.4.0/go.mod h1:/Ct5t2lcmbJ4OSe/waGBoaVvVqtO0bmtfVNex1PFV8g=
-github.com/uber-go/kafka-client v0.2.2 h1:/myHEtL6sFqjtmRMfi6JqNBk3Lh2+xUExUeDt3f8JYI=
-github.com/uber-go/kafka-client v0.2.2/go.mod h1:ujM3r83bEYTsElQUqIkNOosx9b/4pNJ5xd7Q+DBpYFs=
+github.com/uber-go/kafka-client v0.2.3-0.20191018205945-8b3555b395f9 h1:UHlXzsS9nReMag5DU98XlPFlQaLpR8mok9SQbNcrcTs=
+github.com/uber-go/kafka-client v0.2.3-0.20191018205945-8b3555b395f9/go.mod h1:ujM3r83bEYTsElQUqIkNOosx9b/4pNJ5xd7Q+DBpYFs=
 github.com/uber-go/mapdecode v1.0.0 h1:euUEFM9KnuCa1OBixz1xM+FIXmpixyay5DLymceOVrU=
 github.com/uber-go/mapdecode v1.0.0/go.mod h1:b5nP15FwXTgpjTjeA9A2uTHXV5UJCl4arwKpP0FP1Hw=
 github.com/uber-go/tally v3.3.11+incompatible h1:b6xn/zbXCPFID3p2P9nUlHWyrNZ3e3U35Ra1/gDR63I=