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