Commit 6b7a8f2
committed
1 parent 9e43ec9 commit 6b7a8f2
1 file changed
+1
-1
lines changed- src/v/kafka/client/direct_consumer/direct_consumer.cc+3
- src/v/kafka/client/direct_consumer/direct_consumer.h+2
- src/v/kafka/client/direct_consumer/fetcher.cc+163-57
- src/v/kafka/client/direct_consumer/fetcher.h+4-2
- src/v/kafka/client/direct_consumer/tests/BUILD+1
- src/v/kafka/client/direct_consumer/tests/direct_consumer_fixture.cc+22
- src/v/kafka/client/direct_consumer/tests/direct_consumer_fixture.h+4
- src/v/kafka/client/direct_consumer/tests/direct_consumer_fixture_test.cc+40
- src/v/kafka/client/direct_consumer/verifier/application.cc+32
- tests/rptest/direct_consumer_tests/direct_consumer_test.py+72-10
0 commit comments