diff --git a/indexer/msk.tf b/indexer/msk.tf
index 69112991..7b0ed9c4 100644
--- 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
   }
-}
\ No newline at end of file
+}