MINOR: Fixing build (apache#1121)

mumrah · Mar 21, 2024 · c693306 · c693306
1 parent 50178d0
commit c693306
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/core/src/test/scala/integration/kafka/api/AbstractShareConsumerTest.scala b/core/src/test/scala/integration/kafka/api/AbstractShareConsumerTest.scala
@@ -123,7 +123,7 @@ abstract class AbstractShareConsumerTest extends BaseRequestTest {
       records ++= polledRecords.asScala
       records.size >= numRecords
     }
-    TestUtils.pollRecordsUntilTrue(consumer, pollAction, waitTimeMs = 60000,
+    TestUtils.pollShareRecordsUntilTrue(consumer, pollAction, waitTimeMs = 60000,
       msg = s"Timed out before consuming expected $numRecords records. " +
         s"The number consumed was ${records.size}.")
     records

diff --git a/core/src/test/scala/unit/kafka/utils/TestUtils.scala b/core/src/test/scala/unit/kafka/utils/TestUtils.scala
@@ -1135,7 +1135,7 @@ object TestUtils extends Logging {
     }, msg = msg, pause = 0L, waitTimeMs = waitTimeMs)
   }
 
-  def pollRecordsUntilTrue[K, V](shareConsumer: ShareConsumer[K, V],
+  def pollShareRecordsUntilTrue[K, V](shareConsumer: ShareConsumer[K, V],
                                  action: ConsumerRecords[K, V] => Boolean,
                                  msg: => String,
                                  waitTimeMs: Long): Unit = {