1 file changed
+1
-1
lines changed- src/v/kafka/client/direct_consumer/BUILD+1
- src/v/kafka/client/direct_consumer/api_types.h+5
- src/v/kafka/client/direct_consumer/direct_consumer.cc+8-3
- src/v/kafka/client/direct_consumer/direct_consumer.h+2
- src/v/kafka/client/direct_consumer/fetcher.cc+314-36
- src/v/kafka/client/direct_consumer/fetcher.h+122-12
- src/v/kafka/client/direct_consumer/tests/BUILD+61
- src/v/kafka/client/direct_consumer/tests/data_queue_test.cc
- src/v/kafka/client/direct_consumer/tests/direct_consumer_fixture_test.cc+866
- src/v/kafka/client/direct_consumer/tests/direct_consumer_test.cc+106
- src/v/kafka/client/test/BUILD-54
- src/v/kafka/client/test/direct_consumer_fixture_test.cc-199
- tests/rptest/direct_consumer_tests/direct_consumer_test.py+13-4
0 commit comments