| ... |
|
fixtures
|
|
|
fuzzers
|
|
|
interceptor_test
|
|
|
java
|
|
|
plugin_test
|
|
|
scenarios
|
|
|
tools
|
|
|
0000-unittests.c
|
2.65 KB |
|
0001-multiobj.c
|
3.76 KB |
|
0002-unkpart.c
|
8.88 KB |
|
0003-msgmaxsize.c
|
6.46 KB |
|
0004-conf.c
|
33.11 KB |
|
0005-order.c
|
4.57 KB |
|
0006-symbols.c
|
7.67 KB |
|
0007-autotopic.c
|
4.62 KB |
|
0008-reqacks.c
|
6.58 KB |
|
0009-mock_cluster.c
|
3.34 KB |
|
0011-produce_batch.c
|
26.61 KB |
|
0012-produce_consume.c
|
18.84 KB |
|
0013-null-msgs.c
|
16.03 KB |
|
0014-reconsume-191.c
|
18.8 KB |
|
0015-offset_seeks.c
|
6.3 KB |
|
0016-client_swname.c
|
6.49 KB |
|
0017-compression.c
|
5.19 KB |
|
0018-cgrp_term.c
|
11.95 KB |
|
0019-list_groups.c
|
9.57 KB |
|
0020-destroy_hang.c
|
5.69 KB |
|
0021-rkt_destroy.c
|
2.47 KB |
|
0022-consume_batch.c
|
9.05 KB |
|
0025-timers.c
|
5 KB |
|
0026-consume_pause.c
|
20.26 KB |
|
0028-long_topicnames.c
|
2.93 KB |
|
0029-assign_offset.c
|
8.25 KB |
|
0030-offset_commit.c
|
23.02 KB |
|
0031-get_offsets.c
|
8.62 KB |
|
0033-regex_subscribe.c
|
19.1 KB |
|
0034-offset_reset.c
|
15.57 KB |
|
0035-api_version.c
|
2.85 KB |
|
0036-partial_fetch.c
|
3.36 KB |
|
0037-destroy_hang_local.c
|
2.93 KB |
|
0038-performance.c
|
4.83 KB |
|
0039-event.c
|
10.07 KB |
|
0040-io_event.c
|
9.66 KB |
|
0041-fetch_max_bytes.c
|
3.55 KB |
|
0042-many_topics.c
|
8.47 KB |
|
0043-no_connection.c
|
2.71 KB |
|
0044-partition_cnt.c
|
3.25 KB |
|
0045-subscribe_update.c
|
27.14 KB |
|
0046-rkt_cache.c
|
2.28 KB |
|
0047-partial_buf_tmout.c
|
3.67 KB |
|
0048-partitioner.c
|
10.48 KB |
|
0049-consume_conn_close.c
|
5.48 KB |
|
0050-subscribe_adds.c
|
5.03 KB |
|
0051-assign_adds.c
|
4.39 KB |
|
0052-msg_timestamps.c
|
8.5 KB |
|
0053-stats_cb.cpp
|
16.42 KB |
|
0054-offset_time.cpp
|
9.23 KB |
|
0055-producer_latency.c
|
12.31 KB |
|
0056-balanced_group_mt.c
|
11.07 KB |
|
0057-invalid_topic.cpp
|
4 KB |
|
0058-log.cpp
|
3.7 KB |
|
0059-bsearch.cpp
|
7.64 KB |
|
0060-op_prio.cpp
|
5.24 KB |
|
0061-consumer_lag.cpp
|
8.72 KB |
|
0062-stats_event.c
|
4.84 KB |
|
0063-clusterid.cpp
|
6.15 KB |
|
0064-interceptors.c
|
16.27 KB |
|
0065-yield.cpp
|
4.39 KB |
|
0066-plugins.cpp
|
4.06 KB |
|
0067-empty_topic.cpp
|
4.9 KB |
|
0068-produce_timeout.c
|
4.93 KB |
|
0069-consumer_add_parts.c
|
4.36 KB |
|
0070-null_empty.cpp
|
6.76 KB |
|
0072-headers_ut.c
|
17.42 KB |
|
0073-headers.c
|
13.6 KB |
|
0074-producev.c
|
3.28 KB |
|
0075-retry.c
|
8.43 KB |
|
0076-produce_retry.c
|
16.77 KB |
|
0077-compaction.c
|
13.62 KB |
|
0078-c_from_cpp.cpp
|
3.14 KB |
|
0079-fork.c
|
3.22 KB |
|
0080-admin_ut.c
|
121.05 KB |
|
0081-admin.c
|
218.71 KB |
|
0082-fetch_max_bytes.cpp
|
4.57 KB |
|
0083-cb_event.c
|
9.35 KB |
|
0084-destroy_flags.c
|
7.88 KB |
|
0085-headers.cpp
|
12.94 KB |
|
0086-purge.c
|
12.39 KB |
|
0088-produce_metadata_timeout.c
|
5.72 KB |
|
0089-max_poll_interval.c
|
19.47 KB |
|
0090-idempotence.c
|
6.38 KB |
|
0091-max_poll_interval_timeout.c
|
9.82 KB |
|
0092-mixed_msgver.c
|
3.56 KB |
|
0093-holb.c
|
6.96 KB |
|
0094-idempotence_msg_timeout.c
|
8.74 KB |
|
0095-all_brokers_down.cpp
|
3.43 KB |
|
0097-ssl_verify.cpp
|
15.53 KB |
|
0098-consumer-txn.cpp
|
41.97 KB |
|
0099-commit_metadata.c
|
6.82 KB |
|
0100-thread_interceptors.cpp
|
6.46 KB |
|
0101-fetch-from-follower.cpp
|
15.23 KB |
|
0102-static_group_rebalance.c
|
20.57 KB |
|
0103-transactions.c
|
51.99 KB |
|
0104-fetch_from_follower_mock.c
|
23.3 KB |
|
0105-transactions_mock.c
|
147.62 KB |
|
0106-cgrp_sess_timeout.c
|
10.86 KB |
|
0107-topic_recreate.c
|
8.67 KB |
|
0109-auto_create_topics.cpp
|
7.68 KB |
|
0110-batch_size.cpp
|
5.57 KB |
|
0111-delay_create_topics.cpp
|
4.01 KB |
|
0112-assign_unknown_part.c
|
3.9 KB |
|
0113-cooperative_rebalance.cpp
|
115.36 KB |
|
0114-sticky_partitioning.cpp
|
5.72 KB |
|
0115-producer_auth.cpp
|
6.1 KB |
|
0116-kafkaconsumer_close.cpp
|
6.42 KB |
|
0117-mock_errors.c
|
11.09 KB |
|
0118-commit_rebalance.c
|
4.7 KB |
|
0119-consumer_auth.cpp
|
4.44 KB |
|
0120-asymmetric_subscription.c
|
6.23 KB |
|
0121-clusterid.c
|
3.93 KB |
|
0122-buffer_cleaning_after_rebalance.c
|
8.79 KB |
|
0123-connections_max_idle.c
|
3.19 KB |
|
0124-openssl_invalid_engine.c
|
2.78 KB |
|
0125-immediate_flush.c
|
5.05 KB |
|
0126-oauthbearer_oidc.c
|
6.79 KB |
|
0127-fetch_queue_backoff.cpp
|
5.5 KB |
|
0128-sasl_callback_queue.cpp
|
3.91 KB |
|
0129-fetch_aborted_msgs.c
|
3.23 KB |
|
0130-store_offsets.c
|
7.68 KB |
|
0131-connect_timeout.c
|
2.9 KB |
|
0132-strategy_ordering.c
|
7.05 KB |
|
0133-ssl_keys.c
|
5.14 KB |
|
0134-ssl_provider.c
|
3.57 KB |
|
0135-sasl_credentials.cpp
|
4.23 KB |
|
0136-resolve_cb.c
|
6.06 KB |
|
0137-barrier_batch_consume.c
|
21.46 KB |
|
0138-admin_mock.c
|
10.89 KB |
|
0139-offset_validation_mock.c
|
16.81 KB |
|
0140-commit_metadata.cpp
|
3.63 KB |
|
0142-reauthentication.c
|
18.94 KB |
|
0143-exponential_backoff_mock.c
|
24.55 KB |
|
0144-idempotence_mock.c
|
14.13 KB |
|
0145-pause_resume_mock.c
|
4.46 KB |
|
0146-metadata_mock.c
|
16.73 KB |
|
0150-telemetry_mock.c
|
22.78 KB |
|
1000-unktopic.c
|
5.72 KB |
|
8000-idle.cpp
|
1.88 KB |
|
8001-fetch_from_follower_mock_manual.c
|
4.19 KB |
|
autotest.sh
|
564 B |
|
backtrace.gdb
|
199 B |
|
broker_version_tests.py
|
10.42 KB |
|
buildbox.sh
|
251 B |
|
cleanup-checker-tests.sh
|
447 B |
|
cluster_testing.py
|
6.16 KB |
|
CMakeLists.txt
|
4.11 KB |
|
delete-test-topics.sh
|
1.02 KB |
|
gen-ssl-certs.sh
|
3.87 KB |
|
interactive_broker_version.py
|
5.68 KB |
|
librdkafka.suppressions
|
9.4 KB |
|
LibrdkafkaTestApp.py
|
10.92 KB |
|
lz4_manual_test.sh
|
1.66 KB |
|
Makefile
|
4.29 KB |
|
multi-broker-version-test.sh
|
1.06 KB |
|
parse-refcnt.sh
|
752 B |
|
performance_plot.py
|
2.9 KB |
|
README.md
|
17.24 KB |
|
requirements.txt
|
40 B |
|
run-consumer-tests.sh
|
282 B |
|
run-producer-tests.sh
|
282 B |
|
run-test.sh
|
3.03 KB |
|
rusage.c
|
8.92 KB |
|
sasl_test.py
|
11.14 KB |
|
sockem.c
|
22.61 KB |
|
sockem.h
|
2.48 KB |
|
sockem_ctrl.c
|
4.89 KB |
|
sockem_ctrl.h
|
2.14 KB |
|
test.c
|
257.51 KB |
|
test.conf.example
|
681 B |
|
test.h
|
41.06 KB |
|
testcpp.cpp
|
4.03 KB |
|
testcpp.h
|
11.42 KB |
|
testshared.h
|
15.98 KB |
|
until-fail.sh
|
2.08 KB |
|
xxxx-assign_partition.c
|
4.74 KB |
|
xxxx-metadata.cpp
|
5.06 KB |