blob: a9dccfa5e58dcaeffaf7429296dea98cefbcbc9e (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
|
set(
sources
0000-unittests.c
0001-multiobj.c
0002-unkpart.c
0003-msgmaxsize.c
0004-conf.c
0005-order.c
0006-symbols.c
0007-autotopic.c
0008-reqacks.c
0009-mock_cluster.c
0011-produce_batch.c
0012-produce_consume.c
0013-null-msgs.c
0014-reconsume-191.c
0015-offset_seeks.c
0016-client_swname.c
0017-compression.c
0018-cgrp_term.c
0019-list_groups.c
0020-destroy_hang.c
0021-rkt_destroy.c
0022-consume_batch.c
0025-timers.c
0026-consume_pause.c
0028-long_topicnames.c
0029-assign_offset.c
0030-offset_commit.c
0031-get_offsets.c
0033-regex_subscribe.c
0034-offset_reset.c
0035-api_version.c
0036-partial_fetch.c
0037-destroy_hang_local.c
0038-performance.c
0039-event.c
0040-io_event.c
0041-fetch_max_bytes.c
0042-many_topics.c
0043-no_connection.c
0044-partition_cnt.c
0045-subscribe_update.c
0046-rkt_cache.c
0047-partial_buf_tmout.c
0048-partitioner.c
0049-consume_conn_close.c
0050-subscribe_adds.c
0051-assign_adds.c
0052-msg_timestamps.c
0053-stats_cb.cpp
0054-offset_time.cpp
0055-producer_latency.c
0056-balanced_group_mt.c
0057-invalid_topic.cpp
0058-log.cpp
0059-bsearch.cpp
0060-op_prio.cpp
0061-consumer_lag.cpp
0062-stats_event.c
0063-clusterid.cpp
0064-interceptors.c
0065-yield.cpp
0066-plugins.cpp
0067-empty_topic.cpp
0068-produce_timeout.c
0069-consumer_add_parts.c
0070-null_empty.cpp
0072-headers_ut.c
0073-headers.c
0074-producev.c
0075-retry.c
0076-produce_retry.c
0077-compaction.c
0078-c_from_cpp.cpp
0079-fork.c
0080-admin_ut.c
0081-admin.c
0082-fetch_max_bytes.cpp
0083-cb_event.c
0084-destroy_flags.c
0085-headers.cpp
0086-purge.c
0088-produce_metadata_timeout.c
0089-max_poll_interval.c
0090-idempotence.c
0091-max_poll_interval_timeout.c
0092-mixed_msgver.c
0093-holb.c
0094-idempotence_msg_timeout.c
0095-all_brokers_down.cpp
0097-ssl_verify.cpp
0098-consumer-txn.cpp
0099-commit_metadata.c
0100-thread_interceptors.cpp
0101-fetch-from-follower.cpp
0102-static_group_rebalance.c
0103-transactions.c
0104-fetch_from_follower_mock.c
0105-transactions_mock.c
0106-cgrp_sess_timeout.c
0107-topic_recreate.c
0109-auto_create_topics.cpp
0110-batch_size.cpp
0111-delay_create_topics.cpp
0112-assign_unknown_part.c
0113-cooperative_rebalance.cpp
0114-sticky_partitioning.cpp
0115-producer_auth.cpp
0116-kafkaconsumer_close.cpp
0117-mock_errors.c
0118-commit_rebalance.c
0119-consumer_auth.cpp
0120-asymmetric_subscription.c
0121-clusterid.c
0122-buffer_cleaning_after_rebalance.c
0123-connections_max_idle.c
0124-openssl_invalid_engine.c
0125-immediate_flush.c
0126-oauthbearer_oidc.c
0128-sasl_callback_queue.cpp
0129-fetch_aborted_msgs.c
0130-store_offsets.c
0131-connect_timeout.c
0132-strategy_ordering.c
0133-ssl_keys.c
0134-ssl_provider.c
0135-sasl_credentials.cpp
0136-resolve_cb.c
0137-barrier_batch_consume.c
0138-admin_mock.c
8000-idle.cpp
test.c
testcpp.cpp
rusage.c
)
if(NOT WIN32)
list(APPEND sources sockem.c sockem_ctrl.c)
else()
list(APPEND sources ../src/tinycthread.c ../src/tinycthread_extra.c)
endif()
add_executable(test-runner ${sources})
target_link_libraries(test-runner PUBLIC rdkafka++)
add_test(NAME RdKafkaTestInParallel COMMAND test-runner -p5)
add_test(NAME RdKafkaTestSequentially COMMAND test-runner -p1)
add_test(NAME RdKafkaTestBrokerLess COMMAND test-runner -p5 -l)
if(NOT WIN32 AND NOT APPLE)
set(tests_OUTPUT_DIRECTORY ${CMAKE_CURRENT_BINARY_DIR})
add_subdirectory(interceptor_test)
endif()
|
