Add rack aware replica selector to msk config (#135)

dydxprotocol · Oct 14, 2024 · ae0d1e0 · ae0d1e0
1 parent ff2cf70
commit ae0d1e0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/indexer/msk.tf b/indexer/msk.tf
@@ -19,6 +19,7 @@ resource "aws_msk_configuration" "main" {
   message.max.bytes=4194304
   unclean.leader.election.enable=true
   zookeeper.session.timeout.ms=6000
+  replica.selector.class = org.apache.kafka.common.replica.RackAwareReplicaSelector
   PROPERTIES
 
   lifecycle {
@@ -57,4 +58,3 @@ resource "aws_msk_cluster" "main" {
     revision = aws_msk_configuration.main.latest_revision
   }
 }
-