Skip to content

KAFKA-19306: Migrate LogCompactionTester to tools module #19905

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wants to merge 12 commits into
base: trunk
Choose a base branch
from
Open

KAFKA-19306: Migrate LogCompactionTester to tools module #19905

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
12 commits
Select commit Hold shift + click to select a range
f30bf5d
(wip) migrate LogCompactionTester
yunchipang Jun 2, 2025
d12c864
move files to correct locations
yunchipang Jun 5, 2025
387446e
call new Java class in log_compaction_tester.py
yunchipang Jun 11, 2025
1b5f04f
add test description comment; add async stderr reader to externalSort
yunchipang Jun 13, 2025
267ac01
move LogCompactionTester to production code
yunchipang Jun 24, 2025
8e6e10d
add TestUtils dependency
yunchipang Jun 24, 2025
b3a7c98
run spotbugsMain
yunchipang Jun 24, 2025
2fc08b8
override equals() and hashCode() in TestRecord to compare test record…
yunchipang Jun 24, 2025
7bf0cc4
add end of line char to validate output message, to have complete sig…
yunchipang Jun 25, 2025
ca04b4a
Merge remote-tracking branch 'upstream/trunk' into KAFKA-19306-migrat…
yunchipang Jun 25, 2025
b3d74a7
add waitUntilTrue helper in LogCompactionTester
yunchipang Jun 27, 2025
c9a2d74
fix checkStyleMain
yunchipang Jun 27, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
349 changes: 0 additions & 349 deletions core/src/test/scala/kafka/tools/LogCompactionTester.scala
View file
Open in desktop

This file was deleted.

2 changes: 1 addition & 1 deletion tests/kafkatest/services/log_compaction_tester.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -82,7 +82,7 @@ def clean_node(self, node):
node.account.ssh("rm -rf %s" % LogCompactionTester.OUTPUT_DIR, allow_fail=False)

def java_class_name(self):
return "kafka.tools.LogCompactionTester"
return "org.apache.kafka.tools.LogCompactionTester"

@property
def is_done(self):
Expand Down
Loading