 |
|
|
|
.. (parent) |
 |
d |
rwxr-xr-x |
46 |
fixtures
|
 |
d |
rwxr-xr-x |
113 |
fuzzers
|
 |
d |
rwxr-xr-x |
133 |
interceptor_test
|
 |
d |
rwxr-xr-x |
4,096 |
java
|
 |
d |
rwxr-xr-x |
53 |
plugin_test
|
 |
d |
rwxr-xr-x |
101 |
scenarios
|
 |
d |
rwxr-xr-x |
46 |
tools
|
 |
d |
rwxr-xr-x |
41 |
trivup
|
 |
- |
rw-r--r-- |
146 |
.gitignore
|
 |
- |
rw-r--r-- |
2,711 |
0000-unittests.c
|
 |
- |
rw-r--r-- |
4,009 |
0001-multiobj.c
|
 |
- |
rw-r--r-- |
9,098 |
0002-unkpart.c
|
 |
- |
rw-r--r-- |
6,616 |
0003-msgmaxsize.c
|
 |
- |
rw-r--r-- |
36,596 |
0004-conf.c
|
 |
- |
rw-r--r-- |
4,675 |
0005-order.c
|
 |
- |
rw-r--r-- |
7,853 |
0006-symbols.c
|
 |
- |
rw-r--r-- |
4,735 |
0007-autotopic.c
|
 |
- |
rw-r--r-- |
6,733 |
0008-reqacks.c
|
 |
- |
rw-r--r-- |
3,472 |
0009-mock_cluster.c
|
 |
- |
rw-r--r-- |
27,308 |
0011-produce_batch.c
|
 |
- |
rw-r--r-- |
19,290 |
0012-produce_consume.c
|
 |
- |
rw-r--r-- |
16,416 |
0013-null-msgs.c
|
 |
- |
rw-r--r-- |
19,248 |
0014-reconsume-191.c
|
 |
- |
rw-r--r-- |
6,450 |
0015-offset_seeks.c
|
 |
- |
rw-r--r-- |
7,261 |
0016-client_swname.c
|
 |
- |
rw-r--r-- |
5,452 |
0017-compression.c
|
 |
- |
rw-r--r-- |
12,582 |
0018-cgrp_term.c
|
 |
- |
rw-r--r-- |
9,803 |
0019-list_groups.c
|
 |
- |
rw-r--r-- |
5,826 |
0020-destroy_hang.c
|
 |
- |
rw-r--r-- |
2,583 |
0021-rkt_destroy.c
|
 |
- |
rw-r--r-- |
9,426 |
0022-consume_batch.c
|
 |
- |
rw-r--r-- |
5,117 |
0025-timers.c
|
 |
- |
rw-r--r-- |
20,932 |
0026-consume_pause.c
|
 |
- |
rw-r--r-- |
3,021 |
0028-long_topicnames.c
|
 |
- |
rw-r--r-- |
8,462 |
0029-assign_offset.c
|
 |
- |
rw-r--r-- |
23,583 |
0030-offset_commit.c
|
 |
- |
rw-r--r-- |
8,829 |
0031-get_offsets.c
|
 |
- |
rw-r--r-- |
20,145 |
0033-regex_subscribe.c
|
 |
- |
rw-r--r-- |
17,103 |
0034-offset_reset.c
|
 |
- |
rw-r--r-- |
2,918 |
0035-api_version.c
|
 |
- |
rw-r--r-- |
3,487 |
0036-partial_fetch.c
|
 |
- |
rw-r--r-- |
3,001 |
0037-destroy_hang_local.c
|
 |
- |
rw-r--r-- |
4,994 |
0038-performance.c
|
 |
- |
rw-r--r-- |
10,312 |
0039-event.c
|
 |
- |
rw-r--r-- |
10,320 |
0040-io_event.c
|
 |
- |
rw-r--r-- |
3,680 |
0041-fetch_max_bytes.c
|
 |
- |
rw-r--r-- |
8,675 |
0042-many_topics.c
|
 |
- |
rw-r--r-- |
2,773 |
0043-no_connection.c
|
 |
- |
rw-r--r-- |
3,376 |
0044-partition_cnt.c
|
 |
- |
rw-r--r-- |
38,581 |
0045-subscribe_update.c
|
 |
- |
rw-r--r-- |
2,335 |
0046-rkt_cache.c
|
 |
- |
rw-r--r-- |
3,805 |
0047-partial_buf_tmout.c
|
 |
- |
rw-r--r-- |
10,748 |
0048-partitioner.c
|
 |
- |
rw-r--r-- |
5,614 |
0049-consume_conn_close.c
|
 |
- |
rw-r--r-- |
5,210 |
0050-subscribe_adds.c
|
 |
- |
rw-r--r-- |
4,552 |
0051-assign_adds.c
|
 |
- |
rw-r--r-- |
9,435 |
0052-msg_timestamps.c
|
 |
- |
rw-r--r-- |
16,644 |
0053-stats_cb.cpp
|
 |
- |
rw-r--r-- |
9,455 |
0054-offset_time.cpp
|
 |
- |
rw-r--r-- |
19,752 |
0055-producer_latency.c
|
 |
- |
rw-r--r-- |
11,630 |
0056-balanced_group_mt.c
|
 |
- |
rw-r--r-- |
4,093 |
0057-invalid_topic.cpp
|
 |
- |
rw-r--r-- |
3,793 |
0058-log.cpp
|
 |
- |
rw-r--r-- |
7,952 |
0059-bsearch.cpp
|
 |
- |
rw-r--r-- |
5,366 |
0060-op_prio.cpp
|
 |
- |
rw-r--r-- |
9,573 |
0061-consumer_lag.cpp
|
 |
- |
rw-r--r-- |
4,955 |
0062-stats_event.c
|
 |
- |
rw-r--r-- |
6,293 |
0063-clusterid.cpp
|
 |
- |
rw-r--r-- |
18,381 |
0064-interceptors.c
|
 |
- |
rw-r--r-- |
4,495 |
0065-yield.cpp
|
 |
- |
rw-r--r-- |
4,159 |
0066-plugins.cpp
|
 |
- |
rw-r--r-- |
5,139 |
0067-empty_topic.cpp
|
 |
- |
rw-r--r-- |
5,258 |
0068-produce_timeout.c
|
 |
- |
rw-r--r-- |
4,313 |
0069-consumer_add_parts.c
|
 |
- |
rw-r--r-- |
6,924 |
0070-null_empty.cpp
|
 |
- |
rw-r--r-- |
17,841 |
0072-headers_ut.c
|
 |
- |
rw-r--r-- |
13,923 |
0073-headers.c
|
 |
- |
rw-r--r-- |
3,359 |
0074-producev.c
|
 |
- |
rw-r--r-- |
10,347 |
0075-retry.c
|
 |
- |
rw-r--r-- |
17,272 |
0076-produce_retry.c
|
 |
- |
rw-r--r-- |
14,214 |
0077-compaction.c
|
 |
- |
rw-r--r-- |
3,211 |
0078-c_from_cpp.cpp
|
 |
- |
rw-r--r-- |
3,299 |
0079-fork.c
|
 |
- |
rw-r--r-- |
132,879 |
0080-admin_ut.c
|
 |
- |
rw-r--r-- |
235,911 |
0081-admin.c
|
 |
- |
rw-r--r-- |
4,804 |
0082-fetch_max_bytes.cpp
|
 |
- |
rw-r--r-- |
9,955 |
0083-cb_event.c
|
 |
- |
rw-r--r-- |
8,074 |
0084-destroy_flags.c
|
 |
- |
rw-r--r-- |
13,390 |
0085-headers.cpp
|
 |
- |
rw-r--r-- |
14,374 |
0086-purge.c
|
 |
- |
rw-r--r-- |
5,871 |
0088-produce_metadata_timeout.c
|
 |
- |
rw-r--r-- |
20,239 |
0089-max_poll_interval.c
|
 |
- |
rw-r--r-- |
6,548 |
0090-idempotence.c
|
 |
- |
rw-r--r-- |
10,046 |
0091-max_poll_interval_timeout.c
|
 |
- |
rw-r--r-- |
3,858 |
0092-mixed_msgver.c
|
 |
- |
rw-r--r-- |
7,346 |
0093-holb.c
|
 |
- |
rw-r--r-- |
8,997 |
0094-idempotence_msg_timeout.c
|
 |
- |
rw-r--r-- |
3,515 |
0095-all_brokers_down.cpp
|
 |
- |
rw-r--r-- |
24,330 |
0097-ssl_verify.cpp
|
 |
- |
rw-r--r-- |
43,267 |
0098-consumer-txn.cpp
|
 |
- |
rw-r--r-- |
7,229 |
0099-commit_metadata.c
|
 |
- |
rw-r--r-- |
6,616 |
0100-thread_interceptors.cpp
|
 |
- |
rw-r--r-- |
15,613 |
0101-fetch-from-follower.cpp
|
 |
- |
rw-r--r-- |
34,241 |
0102-static_group_rebalance.c
|
 |
- |
rw-r--r-- |
53,362 |
0103-transactions.c
|
 |
- |
rw-r--r-- |
24,318 |
0104-fetch_from_follower_mock.c
|
 |
- |
rw-r--r-- |
151,682 |
0105-transactions_mock.c
|
 |
- |
rw-r--r-- |
12,313 |
0106-cgrp_sess_timeout.c
|
 |
- |
rw-r--r-- |
8,909 |
0107-topic_recreate.c
|
 |
- |
rw-r--r-- |
10,393 |
0109-auto_create_topics.cpp
|
 |
- |
rw-r--r-- |
5,683 |
0110-batch_size.cpp
|
 |
- |
rw-r--r-- |
4,109 |
0111-delay_create_topics.cpp
|
 |
- |
rw-r--r-- |
3,480 |
0112-assign_unknown_part.c
|
 |
- |
rw-r--r-- |
124,170 |
0113-cooperative_rebalance.cpp
|
 |
- |
rw-r--r-- |
5,871 |
0114-sticky_partitioning.cpp
|
 |
- |
rw-r--r-- |
6,309 |
0115-producer_auth.cpp
|
 |
- |
rw-r--r-- |
6,577 |
0116-kafkaconsumer_close.cpp
|
 |
- |
rw-r--r-- |
11,916 |
0117-mock_errors.c
|
 |
- |
rw-r--r-- |
6,620 |
0118-commit_rebalance.c
|
 |
- |
rw-r--r-- |
5,118 |
0119-consumer_auth.cpp
|
 |
- |
rw-r--r-- |
6,615 |
0120-asymmetric_subscription.c
|
 |
- |
rw-r--r-- |
4,029 |
0121-clusterid.c
|
 |
- |
rw-r--r-- |
9,006 |
0122-buffer_cleaning_after_rebalance.c
|
 |
- |
rw-r--r-- |
3,266 |
0123-connections_max_idle.c
|
 |
- |
rw-r--r-- |
2,846 |
0124-openssl_invalid_engine.c
|
 |
- |
rw-r--r-- |
5,185 |
0125-immediate_flush.c
|
 |
- |
rw-r--r-- |
21,648 |
0126-oauthbearer_oidc.c
|
 |
- |
rw-r--r-- |
5,627 |
0127-fetch_queue_backoff.cpp
|
 |
- |
rw-r--r-- |
4,006 |
0128-sasl_callback_queue.cpp
|
 |
- |
rw-r--r-- |
3,355 |
0129-fetch_aborted_msgs.c
|
 |
- |
rw-r--r-- |
7,867 |
0130-store_offsets.c
|
 |
- |
rw-r--r-- |
2,966 |
0131-connect_timeout.c
|
 |
- |
rw-r--r-- |
7,458 |
0132-strategy_ordering.c
|
 |
- |
rw-r--r-- |
6,374 |
0133-ssl_keys.c
|
 |
- |
rw-r--r-- |
3,657 |
0134-ssl_provider.c
|
 |
- |
rw-r--r-- |
4,329 |
0135-sasl_credentials.cpp
|
 |
- |
rw-r--r-- |
6,201 |
0136-resolve_cb.c
|
 |
- |
rw-r--r-- |
22,545 |
0137-barrier_batch_consume.c
|
 |
- |
rw-r--r-- |
11,153 |
0138-admin_mock.c
|
 |
- |
rw-r--r-- |
39,825 |
0139-offset_validation_mock.c
|
 |
- |
rw-r--r-- |
3,731 |
0140-commit_metadata.cpp
|
 |
- |
rw-r--r-- |
20,411 |
0142-reauthentication.c
|
 |
- |
rw-r--r-- |
24,489 |
0143-exponential_backoff_mock.c
|
 |
- |
rw-r--r-- |
14,473 |
0144-idempotence_mock.c
|
 |
- |
rw-r--r-- |
4,563 |
0145-pause_resume_mock.c
|
 |
- |
rw-r--r-- |
19,663 |
0146-metadata_mock.c
|
 |
- |
rw-r--r-- |
39,859 |
0147-consumer_group_consumer_mock.c
|
 |
- |
rw-r--r-- |
24,503 |
0148-offset_fetch_commit_error_mock.c
|
 |
- |
rw-r--r-- |
5,621 |
0149-broker-same-host-port.c
|
 |
- |
rw-r--r-- |
27,828 |
0150-telemetry_mock.c
|
 |
- |
rw-r--r-- |
22,827 |
0151-purge-brokers.c
|
 |
- |
rw-r--r-- |
2,351 |
0152-rebootstrap.c
|
 |
- |
rw-r--r-- |
4,549 |
0153-memberid.c
|
 |
- |
rw-r--r-- |
5,853 |
1000-unktopic.c
|
 |
- |
rw-r--r-- |
1,922 |
8000-idle.cpp
|
 |
- |
rw-r--r-- |
4,286 |
8001-fetch_from_follower_mock_manual.c
|
 |
- |
rw-r--r-- |
4,395 |
CMakeLists.txt
|
 |
- |
rw-r--r-- |
12,507 |
LibrdkafkaTestApp.py
|
 |
- |
rw-r--r-- |
4,390 |
Makefile
|
 |
- |
rw-r--r-- |
17,656 |
README.md
|
 |
- |
rwxr-xr-x |
564 |
autotest.sh
|
 |
- |
rw-r--r-- |
199 |
backtrace.gdb
|
 |
- |
rwxr-xr-x |
10,674 |
broker_version_tests.py
|
 |
- |
rwxr-xr-x |
251 |
buildbox.sh
|
 |
- |
rwxr-xr-x |
447 |
cleanup-checker-tests.sh
|
 |
- |
rwxr-xr-x |
6,308 |
cluster_testing.py
|
 |
- |
rwxr-xr-x |
1,046 |
delete-test-topics.sh
|
 |
- |
rwxr-xr-x |
3,967 |
gen-ssl-certs.sh
|
 |
- |
rwxr-xr-x |
5,813 |
interactive_broker_version.py
|
 |
- |
rw-r--r-- |
9,630 |
librdkafka.suppressions
|
 |
- |
rwxr-xr-x |
1,701 |
lz4_manual_test.sh
|
 |
- |
rwxr-xr-x |
1,087 |
multi-broker-version-test.sh
|
 |
- |
rwxr-xr-x |
752 |
parse-refcnt.sh
|
 |
- |
rwxr-xr-x |
2,965 |
performance_plot.py
|
 |
- |
rw-r--r-- |
40 |
requirements.txt
|
 |
- |
rwxr-xr-x |
2,226 |
run-all-tests.sh
|
 |
- |
rwxr-xr-x |
282 |
run-consumer-tests.sh
|
 |
- |
rwxr-xr-x |
282 |
run-producer-tests.sh
|
 |
- |
rwxr-xr-x |
5,584 |
run-test-batches.py
|
 |
- |
rwxr-xr-x |
3,100 |
run-test.sh
|
 |
- |
rw-r--r-- |
9,137 |
rusage.c
|
 |
- |
rwxr-xr-x |
11,411 |
sasl_test.py
|
 |
- |
rw-r--r-- |
23,150 |
sockem.c
|
 |
- |
rw-r--r-- |
2,542 |
sockem.h
|
 |
- |
rw-r--r-- |
5,003 |
sockem_ctrl.c
|
 |
- |
rw-r--r-- |
2,195 |
sockem_ctrl.h
|
 |
- |
rw-r--r-- |
282,880 |
test.c
|
 |
- |
rw-r--r-- |
681 |
test.conf.example
|
 |
- |
rw-r--r-- |
44,022 |
test.h
|
 |
- |
rw-r--r-- |
4,374 |
testcpp.cpp
|
 |
- |
rw-r--r-- |
12,731 |
testcpp.h
|
 |
- |
rw-r--r-- |
16,870 |
testshared.h
|
 |
- |
rwxr-xr-x |
2,132 |
until-fail.sh
|
 |
- |
rw-r--r-- |
4,857 |
xxxx-assign_partition.c
|
 |
- |
rw-r--r-- |
5,187 |
xxxx-metadata.cpp
|