3 files changed
+61
-2
lines changed| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
28 | 28 | | |
29 | 29 | | |
30 | 30 | | |
| 31 | + | |
31 | 32 | | |
32 | 33 | | |
33 | 34 | | |
| |||
153 | 154 | | |
154 | 155 | | |
155 | 156 | | |
| 157 | + | |
| 158 | + | |
| 159 | + | |
| 160 | + | |
| 161 | + | |
| 162 | + | |
| 163 | + | |
| 164 | + | |
| 165 | + | |
156 | 166 | | |
157 | 167 | | |
158 | 168 | | |
| |||
200 | 210 | | |
201 | 211 | | |
202 | 212 | | |
| 213 | + | |
| 214 | + | |
| 215 | + | |
| 216 | + | |
| 217 | + | |
| 218 | + | |
| 219 | + | |
| 220 | + | |
| 221 | + | |
203 | 222 | | |
204 | 223 | | |
205 | 224 | | |
| |||
241 | 260 | | |
242 | 261 | | |
243 | 262 | | |
| 263 | + | |
| 264 | + | |
| 265 | + | |
| 266 | + | |
| 267 | + | |
| 268 | + | |
| 269 | + | |
| 270 | + | |
| 271 | + | |
244 | 272 | | |
245 | 273 | | |
246 | 274 | | |
| |||
282 | 310 | | |
283 | 311 | | |
284 | 312 | | |
| 313 | + | |
| 314 | + | |
| 315 | + | |
| 316 | + | |
| 317 | + | |
| 318 | + | |
| 319 | + | |
| 320 | + | |
| 321 | + | |
285 | 322 | | |
286 | 323 | | |
287 | 324 | | |
| |||
326 | 363 | | |
327 | 364 | | |
328 | 365 | | |
| 366 | + | |
| 367 | + | |
| 368 | + | |
| 369 | + | |
| 370 | + | |
| 371 | + | |
| 372 | + | |
| 373 | + | |
| 374 | + | |
329 | 375 | | |
330 | 376 | | |
331 | 377 | | |
| |||
402 | 448 | | |
403 | 449 | | |
404 | 450 | | |
| 451 | + | |
| 452 | + | |
| 453 | + | |
| 454 | + | |
| 455 | + | |
| 456 | + | |
| 457 | + | |
| 458 | + | |
| 459 | + | |
| 460 | + | |
| 461 | + | |
| 462 | + | |
| 463 | + | |
405 | 464 | | |
406 | 465 | | |
407 | 466 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
27 | 27 | | |
28 | 28 | | |
29 | 29 | | |
30 | | - | |
| 30 | + | |
31 | 31 | | |
32 | 32 | | |
33 | 33 | | |
| |||
Submodule librdkafka updated 88 files
- .semaphore/semaphore.yml+4-4
- CHANGELOG.md+108
- CONFIGURATION.md+5-3
- INTRODUCTION.md+136-42
- examples/consumer.c+1-1
- mklove/modules/configure.libssl+2-2
- packaging/nuget/packaging.py+1-1
- src-cpp/rdkafkacpp.h+1-1
- src/rdkafka.c+154-2
- src/rdkafka.h+35-1
- src/rdkafka_admin.c+8-8
- src/rdkafka_assignment.c+54-15
- src/rdkafka_assignor.c+3-3
- src/rdkafka_broker.c+12-4
- src/rdkafka_broker.h+7-3
- src/rdkafka_buf.c+2
- src/rdkafka_buf.h+4-2
- src/rdkafka_cgrp.c+1.6k-352
- src/rdkafka_cgrp.h+51-1
- src/rdkafka_conf.c+11-12
- src/rdkafka_conf.h+2-1
- src/rdkafka_int.h+29-8
- src/rdkafka_metadata.c+123-52
- src/rdkafka_metadata.h+15-4
- src/rdkafka_metadata_cache.c+160-45
- src/rdkafka_mock.c+107-3
- src/rdkafka_mock.h+26
- src/rdkafka_mock_handlers.c+49-17
- src/rdkafka_mock_int.h+27
- src/rdkafka_msg.c+47
- src/rdkafka_msg.h+31
- src/rdkafka_msgset_writer.c+2-1
- src/rdkafka_offset.c-2
- src/rdkafka_op.c+2
- src/rdkafka_op.h+12-1
- src/rdkafka_partition.c+256-8
- src/rdkafka_partition.h+49-3
- src/rdkafka_proto.h+59-17
- src/rdkafka_protocol.h+2-1
- src/rdkafka_request.c+592-268
- src/rdkafka_request.h+30-1
- src/rdkafka_ssl.c+2-1
- src/rdkafka_sticky_assignor.c+2-1
- src/rdkafka_topic.c+90-47
- src/rdkafka_topic.h+11
- src/rdkafka_txnmgr.c+3-2
- src/rdmap.c+16
- src/rdmap.h+5
- tests/0009-mock_cluster.c+1-4
- tests/0011-produce_batch.c+179-11
- tests/0016-client_swname.c+1-1
- tests/0018-cgrp_term.c+2-1
- tests/0022-consume_batch.c+3-1
- tests/0026-consume_pause.c+8
- tests/0029-assign_offset.c+6
- tests/0031-get_offsets.c+2-8
- tests/0033-regex_subscribe.c+5-2
- tests/0045-subscribe_update.c+1-4
- tests/0050-subscribe_adds.c+22-2
- tests/0076-produce_retry.c+100
- tests/0104-fetch_from_follower_mock.c+1-4
- tests/0105-transactions_mock.c+1-4
- tests/0106-cgrp_sess_timeout.c+1-4
- tests/0113-cooperative_rebalance.cpp+278-171
- tests/0117-mock_errors.c+1-4
- tests/0120-asymmetric_subscription.c+1-4
- tests/0121-clusterid.c+1-4
- tests/0125-immediate_flush.c+1-4
- tests/0127-fetch_queue_backoff.cpp+7-7
- tests/0138-admin_mock.c+1-4
- tests/0139-offset_validation_mock.c+1-4
- tests/0143-exponential_backoff_mock.c+8-16
- tests/0144-idempotence_mock.c+1-4
- tests/0145-pause_resume_mock.c+119
- tests/0146-metadata_mock.c+272
- tests/8001-fetch_from_follower_mock_manual.c+1-4
- tests/CMakeLists.txt+2
- tests/LibrdkafkaTestApp.py+22-12
- tests/broker_version_tests.py+24-6
- tests/cluster_testing.py+14-6
- tests/interactive_broker_version.py+16-230
- tests/requirements.txt+1-1
- tests/sasl_test.py+10-49
- tests/test.c+100-20
- tests/test.h+26-2
- tests/trivup/trivup-0.12.4.tar.gz
- vcpkg.json+1-1
- win32/tests/tests.vcxproj+2
0 commit comments