Add rack aware replica selector to msk config

dydxprotocol · Sep 26, 2024 · d750e2e · d750e2e
1 parent 44febb8
commit d750e2e
Showing 1 changed file with 2 additions 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 {
@@ -56,4 +57,4 @@ resource "aws_msk_cluster" "main" {
     arn      = aws_msk_configuration.main.arn
     revision = aws_msk_configuration.main.latest_revision
   }
-}
+}