diff --git a/cameleer3-server-app/src/main/java/com/cameleer3/server/app/search/OpenSearchLogIndex.java b/cameleer3-server-app/src/main/java/com/cameleer3/server/app/search/OpenSearchLogIndex.java
index 42f1201f..cf1f7628 100644
--- a/cameleer3-server-app/src/main/java/com/cameleer3/server/app/search/OpenSearchLogIndex.java
+++ b/cameleer3-server-app/src/main/java/com/cameleer3/server/app/search/OpenSearchLogIndex.java
@@ -112,7 +112,7 @@ public class OpenSearchLogIndex {
             if (exchangeId != null && !exchangeId.isEmpty()) {
                 // Match on top-level field (new records) or MDC nested field (old records)
                 bool.must(Query.of(q -> q.bool(b -> b
-                        .should(Query.of(s -> s.term(t -> t.field("exchangeId").value(FieldValue.of(exchangeId)))))
+                        .should(Query.of(s -> s.term(t -> t.field("exchangeId.keyword").value(FieldValue.of(exchangeId)))))
                         .should(Query.of(s -> s.term(t -> t.field("mdc.camel.exchangeId.keyword").value(FieldValue.of(exchangeId)))))
                         .minimumShouldMatch("1"))));
             }