From b10ac206f7b25be3fc172523e1112396a9bae629 Mon Sep 17 00:00:00 2001
From: Yupeng Fu <yupeng@uber.com>
Date: Mon, 27 Jan 2025 12:04:04 -0800
Subject: [PATCH] support lucene10
Signed-off-by: Yupeng Fu <yupeng@uber.com>
---
.../java/org/opensearch/plugin/kafka/IngestFromKafkaIT.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/plugins/ingestion-kafka/src/internalClusterTest/java/org/opensearch/plugin/kafka/IngestFromKafkaIT.java b/plugins/ingestion-kafka/src/internalClusterTest/java/org/opensearch/plugin/kafka/IngestFromKafkaIT.java
index a61b0b49f7481..0f795248f393b 100644
--- a/plugins/ingestion-kafka/src/internalClusterTest/java/org/opensearch/plugin/kafka/IngestFromKafkaIT.java
+++ b/plugins/ingestion-kafka/src/internalClusterTest/java/org/opensearch/plugin/kafka/IngestFromKafkaIT.java
@@ -94,7 +94,7 @@ public void testKafkaIngestion() {
await().atMost(10, TimeUnit.SECONDS).untilAsserted(() -> {
refresh("test");
SearchResponse response = client().prepareSearch("test").setQuery(query).get();
- assertThat(response.getHits().getTotalHits().value, is(1L));
+ assertThat(response.getHits().getTotalHits().value(), is(1L));
});
stopKafka();