You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@hudi.apache.org by "nsivabalan (via GitHub)" <gi...@apache.org> on 2026/06/25 03:39:32 UTC

Re: [I] Track and remove KafkaTestUtil [hudi]

nsivabalan commented on issue #16395:
URL: https://github.com/apache/hudi/issues/16395#issuecomment-4795599056

   This appears to be addressed by #17758 (commit `bd0ae66020ea`, merged 2025-12-31). That PR removed the flaky `spark-streaming-kafka-0-10` test-jar dependency from `hudi-utilities/pom.xml` and replaced the Spark-bundled `KafkaTestUtils` with a local testcontainers-based `KafkaTestUtils` (using `ConfluentKafkaContainer` on `cp-kafka:7.7.1`) at `hudi-utilities/src/test/java/org/apache/hudi/utilities/testutils/KafkaTestUtils.java`. All callers (`BaseTestKafkaSource`, `TestKafkaOffsetGen`, `HoodieDeltaStreamerTestBase`, `TestAvroKafkaSource`, `TestJsonKafkaSourcePostProcessor`, `TestAbstractDebeziumSource`, `TestKafkaCallbackProvider`) were migrated. Likely safe to close HUDI-7409 / this issue — please reopen if you're tracking a separate flakiness concern.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org