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