From 5d64f8cd4fff2a79a364dbe4cda10a7fb6aa04f7 Mon Sep 17 00:00:00 2001
From: Justin Weng <justin.weng@netapp.com>
Date: Fri, 4 Oct 2024 10:39:55 +1000
Subject: [PATCH] Fix local_shotover_broker_id in test configs (#1765)

---
 shotover/src/transforms/kafka/sink_cluster/mod.rs | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/shotover/src/transforms/kafka/sink_cluster/mod.rs b/shotover/src/transforms/kafka/sink_cluster/mod.rs
index 4ba41a4ab..59a8bd5d1 100644
--- a/shotover/src/transforms/kafka/sink_cluster/mod.rs
+++ b/shotover/src/transforms/kafka/sink_cluster/mod.rs
@@ -1516,7 +1516,6 @@ impl KafkaSinkCluster {
         // Take this response as base.
         // Then iterate over all remaining combined responses and integrate them into the base.
         let mut base = drain.next().unwrap();
-        base.invalidate_cache();
 
         match base.frame() {
             Some(Frame::Kafka(KafkaFrame::Response {
@@ -1534,6 +1533,8 @@ impl KafkaSinkCluster {
             }
         }
 
+        base.invalidate_cache();
+
         Ok(base)
     }