From 0495e63852653395661464782eb0d59d5ba6ff07 Mon Sep 17 00:00:00 2001
From: roy-dydx <133032749+roy-dydx@users.noreply.github.com>
Date: Thu, 26 Sep 2024 19:44:28 -0400
Subject: [PATCH] Add rack aware replica selector to msk config (#135)

---
 indexer/msk.tf | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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
+}