-
Notifications
You must be signed in to change notification settings - Fork 0
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
update to latest #1
base: master
Are you sure you want to change the base?
Commits on Jun 29, 2022
-
Configuration menu - View commit details
-
Copy full SHA for a47c74f - Browse repository at this point
Copy the full SHA a47c74fView commit details
Commits on Jul 6, 2022
-
Configuration menu - View commit details
-
Copy full SHA for d747121 - Browse repository at this point
Copy the full SHA d747121View commit details -
Configuration menu - View commit details
-
Copy full SHA for faacc74 - Browse repository at this point
Copy the full SHA faacc74View commit details
Commits on Jul 14, 2022
-
Configuration menu - View commit details
-
Copy full SHA for 4faeb81 - Browse repository at this point
Copy the full SHA 4faeb81View commit details
Commits on Aug 1, 2022
-
Configuration menu - View commit details
-
Copy full SHA for 2b08363 - Browse repository at this point
Copy the full SHA 2b08363View commit details -
Configuration menu - View commit details
-
Copy full SHA for 8521e83 - Browse repository at this point
Copy the full SHA 8521e83View commit details -
Configuration menu - View commit details
-
Copy full SHA for 7167e2e - Browse repository at this point
Copy the full SHA 7167e2eView commit details -
Configuration menu - View commit details
-
Copy full SHA for 937f874 - Browse repository at this point
Copy the full SHA 937f874View commit details -
Configuration menu - View commit details
-
Copy full SHA for 8c29ec8 - Browse repository at this point
Copy the full SHA 8c29ec8View commit details -
Configuration menu - View commit details
-
Copy full SHA for b871fda - Browse repository at this point
Copy the full SHA b871fdaView commit details -
Configuration menu - View commit details
-
Copy full SHA for 9b72ca3 - Browse repository at this point
Copy the full SHA 9b72ca3View commit details
Commits on Oct 3, 2022
-
Configuration menu - View commit details
-
Copy full SHA for 89fe5b3 - Browse repository at this point
Copy the full SHA 89fe5b3View commit details -
Configuration menu - View commit details
-
Copy full SHA for 6147b36 - Browse repository at this point
Copy the full SHA 6147b36View commit details
Commits on Oct 7, 2022
-
Configuration menu - View commit details
-
Copy full SHA for 090cf7b - Browse repository at this point
Copy the full SHA 090cf7bView commit details -
Configuration menu - View commit details
-
Copy full SHA for c8515a2 - Browse repository at this point
Copy the full SHA c8515a2View commit details -
Configuration menu - View commit details
-
Copy full SHA for 0c267a3 - Browse repository at this point
Copy the full SHA 0c267a3View commit details -
Fix for using PKCS#12 keystores on Windows (@emasab, #3999)
* Tests for Ssl PKCS#12 keystore or PEM key and certificate. * Fix for using PKCS#12 keystores on Windows * Automatic SSL keystore generation for future upgrades. * Addressed remaining comments * Addressed second round of comments
Configuration menu - View commit details
-
Copy full SHA for 9faa91b - Browse repository at this point
Copy the full SHA 9faa91bView commit details
Commits on Oct 26, 2022
-
Configuration menu - View commit details
-
Copy full SHA for ee63ae3 - Browse repository at this point
Copy the full SHA ee63ae3View commit details
Commits on Oct 27, 2022
-
Updated zlib download url (#4024) (#4036)
* Updated zlib download url from https://zlib.net/ to https://zlib.net/fossils/ as the former doesn't work for all the versions anymore * Removed changelog changes
Configuration menu - View commit details
-
Copy full SHA for 2aa5fac - Browse repository at this point
Copy the full SHA 2aa5facView commit details
Commits on Oct 28, 2022
-
Configuration menu - View commit details
-
Copy full SHA for 259e075 - Browse repository at this point
Copy the full SHA 259e075View commit details -
Configuration menu - View commit details
-
Copy full SHA for 0c95281 - Browse repository at this point
Copy the full SHA 0c95281View commit details -
Configuration menu - View commit details
-
Copy full SHA for 576db05 - Browse repository at this point
Copy the full SHA 576db05View commit details -
Configuration menu - View commit details
-
Copy full SHA for 3709caa - Browse repository at this point
Copy the full SHA 3709caaView commit details -
Require trivup >= 0.11.0 for proper DES PKCS#12 generation
since OpenSSL 3 does not support RC2 out of the box (legacy provider needed).
Configuration menu - View commit details
-
Copy full SHA for 96be433 - Browse repository at this point
Copy the full SHA 96be433View commit details -
Configuration menu - View commit details
-
Copy full SHA for 09bc067 - Browse repository at this point
Copy the full SHA 09bc067View commit details -
Configuration menu - View commit details
-
Copy full SHA for 7aa62f9 - Browse repository at this point
Copy the full SHA 7aa62f9View commit details -
Configuration menu - View commit details
-
Copy full SHA for 327e3e6 - Browse repository at this point
Copy the full SHA 327e3e6View commit details -
Configuration menu - View commit details
-
Copy full SHA for b4e35df - Browse repository at this point
Copy the full SHA b4e35dfView commit details
Commits on Oct 29, 2022
-
Configuration menu - View commit details
-
Copy full SHA for 75a243f - Browse repository at this point
Copy the full SHA 75a243fView commit details
Commits on Nov 1, 2022
-
Config: remove upper limit on queue.buffering.max.messages (#4018) (#…
…4022) * Config: remove upper limit on queue.buffering.max.messages (#4018) The current limit of 10 million messages is quite low when using compression Users may also want to bound the queue by it's memory usage exclusively * typos in rdkafka_conf.c Co-authored-by: Magnus Edenhill <[email protected]> * remove diffs from configuration.md * undo enum formatting Co-authored-by: Magnus Edenhill <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for e0b9e92 - Browse repository at this point
Copy the full SHA e0b9e92View commit details
Commits on Nov 2, 2022
-
Add interceptor for broker state change (#4043)
* Add interceptor for broker state change * Update CHANGELOG.md Co-authored-by: Magnus Edenhill <[email protected]> Co-authored-by: Magnus Edenhill <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for 2c1a49e - Browse repository at this point
Copy the full SHA 2c1a49eView commit details -
Configuration menu - View commit details
-
Copy full SHA for 886181a - Browse repository at this point
Copy the full SHA 886181aView commit details
Commits on Nov 3, 2022
-
rdkafkacpp: Eliminate "return by const value" pessimizations. (#3966)
Returning a `const string` means "My caller can have a copy of this string, but they aren't allowed to modify it" -- for example, they aren't allowed to use move semantics to move-out-of the returned string. Thus `x = y.name();` will use copy assignment rather than move assignment. This is a needless pessimization in C++11 and later. See also the errata marked "nxd" in https://www.aristeia.com/BookErrata/ec++3e-errata.html Co-authored-by: Magnus Edenhill <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for 4fd651d - Browse repository at this point
Copy the full SHA 4fd651dView commit details -
Configuration menu - View commit details
-
Copy full SHA for dd4a5b1 - Browse repository at this point
Copy the full SHA dd4a5b1View commit details
Commits on Nov 4, 2022
-
A NULL coordinator shouldn't be fatal (#4020)
* Test that a NULL txn coordinator is not fatal if an failed FindCoordinatorRequest sets txn coordinator to NULL just after it reconnects. * Fix for the assert that is giving the fatal error rd_kafka_idemp_pid_fsm: Assertion `rk->rk_eos.txn_curr_coord' failed * Updated CHANGELOG * Addressed PR comments * Style fix Co-authored-by: Magnus Edenhill <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for e98340b - Browse repository at this point
Copy the full SHA e98340bView commit details -
Configuration menu - View commit details
-
Copy full SHA for bbf1a31 - Browse repository at this point
Copy the full SHA bbf1a31View commit details -
Handle COORDINATOR_LOAD_IN_PROGRESS in err_action (#4048)
* Handle COORDINATOR_LOAD_IN_PROGRESS in err_action * Add unit test * Add changelog entry * Address review comments * Address build failure Co-authored-by: Matt Howlett <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for 3ded8ee - Browse repository at this point
Copy the full SHA 3ded8eeView commit details -
Read all certificates from ssl.ca.pem, not just the first one (#4049)
* Read all certificates from ssl.ca.pem, not just the first one Reported in confluentinc/confluent-kafka-go#827 * Fix memory leak when reading DER-encoded certificates
Configuration menu - View commit details
-
Copy full SHA for f8830a2 - Browse repository at this point
Copy the full SHA f8830a2View commit details
Commits on Nov 7, 2022
-
rdkafkacpp: Remove bogus semicolons after function bodies. NFC.
Cascading changes due to the clang-format commit hook.
Configuration menu - View commit details
-
Copy full SHA for 47db428 - Browse repository at this point
Copy the full SHA 47db428View commit details
Commits on Nov 8, 2022
-
Remove warning for allow.auto.create.topics with producer
Also improves the documentation around this property. This solves the following problem: The property "allow.auto.create.topics" is supposed to be a consumer property, but we are setting it (and it is affecting the behaviour of) both the consumer and producer. It gives a warning if we change it in the producer, but works nevertheless. (the default value for the producer is true) One of the effects is that if a user is using their producer as an adminclient, a call to get metadata for a topic might create that topic, and if the user specifies allow.auto.create.topics, then they get a warning. Unfortunately, we even recommend using a producer with the above setting (see INTRODUCTION.md). A knock on effect is that both the go and python clients use a producer internally for their adminclients so the user has to either live with a call to GetMetadata creating topics, or with the warning. The java client only allows this property to be set on the consumer, which makes it more confusing.
Configuration menu - View commit details
-
Copy full SHA for 42e530c - Browse repository at this point
Copy the full SHA 42e530cView commit details
Commits on Nov 9, 2022
-
Added rd_kafka_sasl_set_credentials() (#4033)
Co-authored-by: Jos Visser <[email protected]> Co-authored-by: edenhill <[email protected]> Co-authored-by: edenhill <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for 3b50e1e - Browse repository at this point
Copy the full SHA 3b50e1eView commit details -
Add more explicit .clang-format files and warn if clang-format versio…
…n != 10 Using the --dump-files option on clang-format-10, this guards against any changes to the defaults, or changes to the 'BasedOnStyle' styles. For .clang-format-cpp, because of the way we are using it in the script by converting it to the key/value format, a number of options from the --dump-files option has to be omitted, hence why we need to retain the BasedOnStyle. For .clang-format, we no longer need this. Additionally, style-format.sh warns in case clang-format version is not 10 or 11.
Configuration menu - View commit details
-
Copy full SHA for ba9d42c - Browse repository at this point
Copy the full SHA ba9d42cView commit details -
Disable syslog for static OSX artifacts
Since it's not generally available across OSX versions
Configuration menu - View commit details
-
Copy full SHA for ec73301 - Browse repository at this point
Copy the full SHA ec73301View commit details
Commits on Nov 11, 2022
-
Configuration menu - View commit details
-
Copy full SHA for 51b6e0c - Browse repository at this point
Copy the full SHA 51b6e0cView commit details
Commits on Nov 15, 2022
-
Configuration menu - View commit details
-
Copy full SHA for 4c51ce5 - Browse repository at this point
Copy the full SHA 4c51ce5View commit details -
Fix the batch.size condition on the produce path
When the batch.size is exceeded, we will close and send the current batch. In case compression is enabled, we "inflate" the batch size by 8x for the purposes of this check. At least, that's the intent. Currently the condition is reversed: the 8x inflation happens if compression is disabled, not the other way around. The effect is that messages linger for longer than expected in the queue, as if the batch size was 8x larger. They are still sent respecting the batch size however, since this occurs at a different location. This change removes the 8x inflation entirely: instead we use the batch size as the threshold regardless of whether compression is enabled per the discussion on the PR. Fixes #4055.
Configuration menu - View commit details
-
Copy full SHA for bee6497 - Browse repository at this point
Copy the full SHA bee6497View commit details
Commits on Nov 17, 2022
-
Allow overriding DNS resolution
Introduce a new `resolve_cb` configuration parameter for controlling DNS resolution. When provided, librdkafka invokes the callback when resolving the address of a Kafka broker instead of calling `getaddrinfo` directly. The callback is expected to function exactly as `getaddrinfo`, except that it is additional provided with the `opaque` value. The callback will enable tunneling to a Kafka broker (e.g., via SSH or AWS PrivateLink). The broker addresses returned by the bootstrap protocol will not be directly routable from the client; the address resolution callback allows the end user to rewrite the broker addresses as appropriate for the tunnel.
Configuration menu - View commit details
-
Copy full SHA for 62d3516 - Browse repository at this point
Copy the full SHA 62d3516View commit details -
Configuration menu - View commit details
-
Copy full SHA for 078f067 - Browse repository at this point
Copy the full SHA 078f067View commit details -
Configuration menu - View commit details
-
Copy full SHA for 2e3bbf9 - Browse repository at this point
Copy the full SHA 2e3bbf9View commit details -
Configuration menu - View commit details
-
Copy full SHA for 0f4065a - Browse repository at this point
Copy the full SHA 0f4065aView commit details -
Abort transaction before bumping the epoch
Co-authored-by: Emanuele Sabellico <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for 9d85c5a - Browse repository at this point
Copy the full SHA 9d85c5aView commit details -
Added rd_kafka_mock_broker_error_stack_cnt()
Co-authored-by: Emanuele Sabellico <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for 9ab0f06 - Browse repository at this point
Copy the full SHA 9ab0f06View commit details -
style-format: avoid file write access if no tabs need converting
Previously, despite if there were no tabs, sed's inplace would modify the file which changed the mtime.
Configuration menu - View commit details
-
Copy full SHA for 595f882 - Browse repository at this point
Copy the full SHA 595f882View commit details -
Configuration menu - View commit details
-
Copy full SHA for 69def0d - Browse repository at this point
Copy the full SHA 69def0dView commit details -
Configuration menu - View commit details
-
Copy full SHA for 929e15d - Browse repository at this point
Copy the full SHA 929e15dView commit details -
Configuration menu - View commit details
-
Copy full SHA for 51985c7 - Browse repository at this point
Copy the full SHA 51985c7View commit details
Commits on Nov 24, 2022
-
Configuration menu - View commit details
-
Copy full SHA for e1a1231 - Browse repository at this point
Copy the full SHA e1a1231View commit details -
Configuration menu - View commit details
-
Copy full SHA for bf9c05f - Browse repository at this point
Copy the full SHA bf9c05fView commit details -
Configuration menu - View commit details
-
Copy full SHA for b197ee3 - Browse repository at this point
Copy the full SHA b197ee3View commit details -
Configuration menu - View commit details
-
Copy full SHA for d359323 - Browse repository at this point
Copy the full SHA d359323View commit details -
Configuration menu - View commit details
-
Copy full SHA for 4331717 - Browse repository at this point
Copy the full SHA 4331717View commit details -
Configuration menu - View commit details
-
Copy full SHA for 33fee4c - Browse repository at this point
Copy the full SHA 33fee4cView commit details
Commits on Nov 28, 2022
-
Configuration menu - View commit details
-
Copy full SHA for febf7ac - Browse repository at this point
Copy the full SHA febf7acView commit details
Commits on Nov 29, 2022
-
Configuration menu - View commit details
-
Copy full SHA for 39713ae - Browse repository at this point
Copy the full SHA 39713aeView commit details
Commits on Nov 30, 2022
-
Configuration menu - View commit details
-
Copy full SHA for 2b52ab4 - Browse repository at this point
Copy the full SHA 2b52ab4View commit details -
Make coord_req()s delayable, and delay TxnOffsetCommitRequests to avo…
…id busy-looping Co-authored-by: Emanuele Sabellico <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for 4f1cc52 - Browse repository at this point
Copy the full SHA 4f1cc52View commit details -
Configuration menu - View commit details
-
Copy full SHA for 714e13a - Browse repository at this point
Copy the full SHA 714e13aView commit details -
Fix assert on resumed txn call when error was set after previous resu…
…mable call returned This is a regression from the previous refactoring.
Configuration menu - View commit details
-
Copy full SHA for 556b557 - Browse repository at this point
Copy the full SHA 556b557View commit details -
Fix refactor regression in send_offsets_to_transaction()
The current API was not being reset properly when there were no offsets to send.
Configuration menu - View commit details
-
Copy full SHA for deb1ad8 - Browse repository at this point
Copy the full SHA deb1ad8View commit details -
Tests 0105: use shorter connection setup timeout..
..since downed mock brokers will not reject new connections, just time them out.
Configuration menu - View commit details
-
Copy full SHA for a52b510 - Browse repository at this point
Copy the full SHA a52b510View commit details -
Let init_transactions() time out even if timeout is infinite
The implicit timeout in this case is currently 2 * transaction.timeout.ms, and the reason is that without a finite timeout there is no way to interrupt the call in the case a coordinator is not available.
Configuration menu - View commit details
-
Copy full SHA for cc88ea8 - Browse repository at this point
Copy the full SHA cc88ea8View commit details -
Try to avoid master references when possible
Signed-off-by: Sergio Arroutbi <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for cd955b1 - Browse repository at this point
Copy the full SHA cd955b1View commit details
Commits on Dec 15, 2022
-
Configuration menu - View commit details
-
Copy full SHA for bfd56d2 - Browse repository at this point
Copy the full SHA bfd56d2View commit details -
Configuration menu - View commit details
-
Copy full SHA for 0b9cf1a - Browse repository at this point
Copy the full SHA 0b9cf1aView commit details -
Configuration menu - View commit details
-
Copy full SHA for ff4ae6b - Browse repository at this point
Copy the full SHA ff4ae6bView commit details -
Configuration menu - View commit details
-
Copy full SHA for a849b0b - Browse repository at this point
Copy the full SHA a849b0bView commit details -
Configuration menu - View commit details
-
Copy full SHA for 8d197f9 - Browse repository at this point
Copy the full SHA 8d197f9View commit details -
Configuration menu - View commit details
-
Copy full SHA for 0add5dd - Browse repository at this point
Copy the full SHA 0add5ddView commit details -
Configuration menu - View commit details
-
Copy full SHA for 3dc1bd0 - Browse repository at this point
Copy the full SHA 3dc1bd0View commit details -
Configuration menu - View commit details
-
Copy full SHA for 771554a - Browse repository at this point
Copy the full SHA 771554aView commit details -
Configuration menu - View commit details
-
Copy full SHA for 41f86bc - Browse repository at this point
Copy the full SHA 41f86bcView commit details -
Configuration menu - View commit details
-
Copy full SHA for 34956aa - Browse repository at this point
Copy the full SHA 34956aaView commit details -
Configuration menu - View commit details
-
Copy full SHA for 4b9a6c7 - Browse repository at this point
Copy the full SHA 4b9a6c7View commit details -
Configuration menu - View commit details
-
Copy full SHA for 95454ab - Browse repository at this point
Copy the full SHA 95454abView commit details
Commits on Dec 16, 2022
-
Configuration menu - View commit details
-
Copy full SHA for 2471158 - Browse repository at this point
Copy the full SHA 2471158View commit details -
Configuration menu - View commit details
-
Copy full SHA for a83cadf - Browse repository at this point
Copy the full SHA a83cadfView commit details
Commits on Dec 21, 2022
-
Configuration menu - View commit details
-
Copy full SHA for 8e20e1e - Browse repository at this point
Copy the full SHA 8e20e1eView commit details -
Configuration menu - View commit details
-
Copy full SHA for ef20081 - Browse repository at this point
Copy the full SHA ef20081View commit details -
Configuration menu - View commit details
-
Copy full SHA for 66f9bc5 - Browse repository at this point
Copy the full SHA 66f9bc5View commit details -
Configuration menu - View commit details
-
Copy full SHA for 842d640 - Browse repository at this point
Copy the full SHA 842d640View commit details -
Configuration menu - View commit details
-
Copy full SHA for dc9fdf4 - Browse repository at this point
Copy the full SHA dc9fdf4View commit details -
Configuration menu - View commit details
-
Copy full SHA for b572115 - Browse repository at this point
Copy the full SHA b572115View commit details -
Configuration menu - View commit details
-
Copy full SHA for 7158892 - Browse repository at this point
Copy the full SHA 7158892View commit details
Commits on Jan 3, 2023
-
Configuration menu - View commit details
-
Copy full SHA for 137ce7d - Browse repository at this point
Copy the full SHA 137ce7dView commit details
Commits on Jan 4, 2023
-
Implement KIP-88, KIP-222, KIP-518 and partially KIP-396 (#3995)
Add support for: KIP-88, KIP-222: ListConsumerGroups, DescribeConsumerGroups, ListConsumerGroupOffsets, KIP-396: AlterConsumerGroupOffsets, KIP-518. Co-authored-by: Lester Fan <[email protected]> Co-authored-by: Magnus Edenhill <[email protected]> Co-authored-by: Milind L <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for 1f9f245 - Browse repository at this point
Copy the full SHA 1f9f245View commit details -
Configuration menu - View commit details
-
Copy full SHA for fe2c5f4 - Browse repository at this point
Copy the full SHA fe2c5f4View commit details
Commits on Jan 9, 2023
-
Configuration menu - View commit details
-
Copy full SHA for 0e4b551 - Browse repository at this point
Copy the full SHA 0e4b551View commit details
Commits on Jan 11, 2023
-
Configuration menu - View commit details
-
Copy full SHA for d6c9fd2 - Browse repository at this point
Copy the full SHA d6c9fd2View commit details
Commits on Jan 13, 2023
-
Configuration menu - View commit details
-
Copy full SHA for 6f32d2d - Browse repository at this point
Copy the full SHA 6f32d2dView commit details -
Configuration menu - View commit details
-
Copy full SHA for 6a66f95 - Browse repository at this point
Copy the full SHA 6a66f95View commit details
Commits on Jan 19, 2023
-
Configuration menu - View commit details
-
Copy full SHA for 96a70a7 - Browse repository at this point
Copy the full SHA 96a70a7View commit details -
Configuration menu - View commit details
-
Copy full SHA for 83ab3fc - Browse repository at this point
Copy the full SHA 83ab3fcView commit details
Commits on Jan 20, 2023
-
Configuration menu - View commit details
-
Copy full SHA for 292d2a6 - Browse repository at this point
Copy the full SHA 292d2a6View commit details
Commits on Jan 27, 2023
-
Configuration menu - View commit details
-
Copy full SHA for 1440f19 - Browse repository at this point
Copy the full SHA 1440f19View commit details
Commits on Feb 2, 2023
-
Configuration menu - View commit details
-
Copy full SHA for 476c9ac - Browse repository at this point
Copy the full SHA 476c9acView commit details
Commits on Feb 6, 2023
-
chore: update repo semaphore project (#4136)
Co-authored-by: Confluent Jenkins Bot <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for dc500f4 - Browse repository at this point
Copy the full SHA dc500f4View commit details
Commits on Feb 9, 2023
-
Set the max available ApiVersionRequest version (#4185)
correctly to avoid errors if version 4 will be implemented. Receiving the list of supported ApiVersionRequest only if broker max version is less than 3
Configuration menu - View commit details
-
Copy full SHA for ecf3fa5 - Browse repository at this point
Copy the full SHA ecf3fa5View commit details -
Configuration menu - View commit details
-
Copy full SHA for 883567a - Browse repository at this point
Copy the full SHA 883567aView commit details
Commits on Feb 10, 2023
-
Set socket connection setup timeout in 0105:do_test_txn_concurrent_op…
…erations (#4186) While using create_txn_producer for any test, we set the socket.connection.setup.timeout.ms to 5s, see a6a5e53 . However, for this test, we are setting the mock broker's RTT to 5s, and due to the fact that we might make the ApiVersionRequest twice (once with version 3, and then with version 0 when the first one fails), this test fails. To remedy this, we make the socket.connection.setup.timeout.ms 3*RTT (2* for taking into account the ApiVersionRequest, and the extra 1* for some buffer)
Configuration menu - View commit details
-
Copy full SHA for 076405e - Browse repository at this point
Copy the full SHA 076405eView commit details
Commits on Feb 21, 2023
-
Configuration menu - View commit details
-
Copy full SHA for c75eae8 - Browse repository at this point
Copy the full SHA c75eae8View commit details
Commits on Mar 10, 2023
-
Temporary fix for CoApp discontinuation (#4211)
Disabled Windows MSVC NuGet package job, Needs an alternative before next release.
Configuration menu - View commit details
-
Copy full SHA for 42bd862 - Browse repository at this point
Copy the full SHA 42bd862View commit details -
Fix close blocked by reference count in test 0113. (#4187)
Breaks a circular dependency from rko to rktp and back that prevents the toppar from being destroyed
Configuration menu - View commit details
-
Copy full SHA for bd8f2a6 - Browse repository at this point
Copy the full SHA bd8f2a6View commit details -
Fix ListGroup protocol message for ApiVersion >= 3 (#4207)
Co-authored-by: Emanuele Sabellico <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for 578589d - Browse repository at this point
Copy the full SHA 578589dView commit details
Commits on Mar 13, 2023
-
Don't reset max.poll.interval.ms limit on every poll (#4176)
Earlier on, we changed the code to prevent max.poll.interval.ms from being triggered in case we were inside librdkafka in any sort of a poll call. Top achieve this, blocked the timer using rd_kafka_app_poll_blocking, and reset it at the end of the call. This doesn't work correctly in the cases where we're simply polling an unrelated queue, like the log queue. In that case, just by polling the log queue, the timer is reset, despite us not actually consuming anything (or doing any consume poll). At the same time, it's a reasonable expectation that max.poll.interval.ms won't be triggered while we are doing any sort of consumer poll. This commit takes care of both the cases. The methods (from public API) which block/reset the timer are: rd_kafka_consume_batch rd_kafka_consume_batch_queue rd_kafka_consume_callback rd_kafka_consume_callback_queue rd_kafka_consume rd_kafka_consumer_poll
Configuration menu - View commit details
-
Copy full SHA for 5f71083 - Browse repository at this point
Copy the full SHA 5f71083View commit details
Commits on Mar 17, 2023
-
Configuration menu - View commit details
-
Copy full SHA for 30729e2 - Browse repository at this point
Copy the full SHA 30729e2View commit details -
Fix warning for duplicate OPENSSL_SUPPRESS_DEPRECATED definition (#4218)
Use a config.h definition instead of a CFLAG
Configuration menu - View commit details
-
Copy full SHA for 2345c73 - Browse repository at this point
Copy the full SHA 2345c73View commit details
Commits on Mar 21, 2023
-
Configuration menu - View commit details
-
Copy full SHA for 2058492 - Browse repository at this point
Copy the full SHA 2058492View commit details -
Revert "Fix timeout unit in rd_kafka_seek_partitions"
This reverts commit 2058492.
Configuration menu - View commit details
-
Copy full SHA for fd170b9 - Browse repository at this point
Copy the full SHA fd170b9View commit details
Commits on Mar 22, 2023
-
Configuration menu - View commit details
-
Copy full SHA for 2bdd39e - Browse repository at this point
Copy the full SHA 2bdd39eView commit details -
Fixed issues related to store_offset and app_offset during barrier op…
… in consume batch API (#4208) these offsets were set before the batch was completed, making it possible to commit offsets that had not been received by the application, or to skip messages after a resume
Configuration menu - View commit details
-
Copy full SHA for 5139719 - Browse repository at this point
Copy the full SHA 5139719View commit details -
Fix test 0086 often failing (#4228)
* Increase linger ms and reducing second batch size to avoid sending a second batch when the first batch is purged in flight * Increase sockem stall * setting delay after first request to ensure a timeout in every case
Configuration menu - View commit details
-
Copy full SHA for 44bd65c - Browse repository at this point
Copy the full SHA 44bd65cView commit details -
Configuration menu - View commit details
-
Copy full SHA for f2b8d01 - Browse repository at this point
Copy the full SHA f2b8d01View commit details -
Update lz4 from upstream (#4232)
Co-authored-by: Suzy Wang <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for ac35618 - Browse repository at this point
Copy the full SHA ac35618View commit details -
KIP-320 : Allow fetchers to detect and handle log truncation (#4162)
Co-authored-by: Magnus Edenhill <[email protected]> Co-authored-by: Milind L <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for a0871a1 - Browse repository at this point
Copy the full SHA a0871a1View commit details
Commits on Mar 30, 2023
-
Configuration menu - View commit details
-
Copy full SHA for 2c00d2c - Browse repository at this point
Copy the full SHA 2c00d2cView commit details -
Configuration menu - View commit details
-
Copy full SHA for a7ddb1e - Browse repository at this point
Copy the full SHA a7ddb1eView commit details
Commits on Mar 31, 2023
-
Configuration menu - View commit details
-
Copy full SHA for 8914c9b - Browse repository at this point
Copy the full SHA 8914c9bView commit details
Commits on Apr 3, 2023
-
Replace coapp with zip package (#4244)
* Packaging with Windows zip package * Use 7z instead of Compress-Archive that uses backslashes in Windows PowerShell 1.0
Configuration menu - View commit details
-
Copy full SHA for 2c6dd0a - Browse repository at this point
Copy the full SHA 2c6dd0aView commit details
Commits on Apr 19, 2023
-
Configuration menu - View commit details
-
Copy full SHA for 751b3fa - Browse repository at this point
Copy the full SHA 751b3faView commit details -
Fix segfault when a fetch from follower lease expires (#4254)
and the partition is waiting for a list offsets result closes #4195
Configuration menu - View commit details
-
Copy full SHA for 3de70e4 - Browse repository at this point
Copy the full SHA 3de70e4View commit details
Commits on Apr 20, 2023
-
Fix duplicate message on validate offset (#4261)
a fetch in the middle of an offset validation is discarded, not producing a duplicate. fixes #4249
Configuration menu - View commit details
-
Copy full SHA for 497b8f2 - Browse repository at this point
Copy the full SHA 497b8f2View commit details -
Fix CMake pkg-config issues (#4180)
The name of curl library is libcurl instead of curl. WITH_SSL also needs libcrypto. Requires.private is more appropriate the Requires. Include cURL headers not publicly, they are only used in .c files. Co-authored-by: FantasqueX <[email protected]> Co-authored-by: Hermann von Kleist <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for 295ba3c - Browse repository at this point
Copy the full SHA 295ba3cView commit details
Commits on Apr 21, 2023
-
exclude the case where the topic is Light-weight
Configuration menu - View commit details
-
Copy full SHA for 081fd97 - Browse repository at this point
Copy the full SHA 081fd97View commit details -
Configuration menu - View commit details
-
Copy full SHA for d16fe07 - Browse repository at this point
Copy the full SHA d16fe07View commit details -
Add flag to rd_kafka_queue which denotes if it contains fetched msgs (#…
…4256) Add failing tests An issue in v2.1.0 was fixed in which max.poll.interval.ms was not honored, because it was reset on any queue poll, not just consumer poll. It was changed it so that only certain rdkafka.h functions which were polling would reset the timer. However, librdkafka exposes a method rd_kafka_queue_get_consumer, which returns the consumer queue, and the application can poll this queue for events rather than calling consume poll. There is no way to distinguish polls to this queue and an arbitrary queue, and it won't reset the timer. So, a new flag is maintained inside the queue denoting if it might contain fetched messages, or not. It deals with forwarding of queues, so if a queue which receives fetched messages is forwarded multiple times, calling poll on the forwardee will also reset the timer. --------- Co-authored-by: Emanuele Sabellico <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for b0b5bfe - Browse repository at this point
Copy the full SHA b0b5bfeView commit details -
Configuration menu - View commit details
-
Copy full SHA for 838a115 - Browse repository at this point
Copy the full SHA 838a115View commit details
Commits on Apr 24, 2023
-
introduced offset validation position to avoid touching the next fetch pos that has a different purpose. Update latest Kafka version. Skip 0139 mock tests when testing with authentication
Configuration menu - View commit details
-
Copy full SHA for 3fa4f4f - Browse repository at this point
Copy the full SHA 3fa4f4fView commit details -
'leader_epoch_' variable is assigned to itself. Co-authored-by: Pave Pimenov <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for ffb8cd1 - Browse repository at this point
Copy the full SHA ffb8cd1View commit details
Commits on Apr 28, 2023
-
Configuration menu - View commit details
-
Copy full SHA for c282ba2 - Browse repository at this point
Copy the full SHA c282ba2View commit details
Commits on May 15, 2023
-
Fix number of bytes skipped when receiving tags. (#4278)
Not being for a nullable field, those unsigned varints don't start from 1 fixes #4253
Configuration menu - View commit details
-
Copy full SHA for 8c8f8b9 - Browse repository at this point
Copy the full SHA 8c8f8b9View commit details
Commits on May 16, 2023
-
Add protocol/parsing changes [KIP-881] (#4189)
* Change embedded MemberMetadata protocol [KIP-881] * Change parsing of Metadata to extract broker racks [KIP-881] * Metadata refactor to add internal fields (#4279) * Metadata and leader epoch refactor. store private metadata into a struct that contains the public one. Co-authored-by: Emanuele Sabellico <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for bc933a0 - Browse repository at this point
Copy the full SHA bc933a0View commit details -
Store offset commit metadata when calling
rd_kafka_offsets_store
(#……4171) store metadata when committing stored offset, in C and C++ --------- Co-authored-by: Mathis <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for 68455af - Browse repository at this point
Copy the full SHA 68455afView commit details
Commits on May 22, 2023
-
Fix segmentation fault when subscribing to a non-existent topic (#4273)
when using one of the consume batch functions and subscribing to non-existent topics, a segfault was triggered. Solved by testing for a non-NULL `rko_rktp`
Configuration menu - View commit details
-
Copy full SHA for 4b63c6c - Browse repository at this point
Copy the full SHA 4b63c6cView commit details
Commits on Jun 5, 2023
-
[consumer] Trigger a rejoin on partition racks' change [KIP-881] (#4291)
* [consumer] Trigger a rejoin on partition racks' change [KIP-881] * Reduce test length by breaking earlier (#4299) once `min_events` are processed in the positive case * Address review comments --------- Co-authored-by: Emanuele Sabellico <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for f608e34 - Browse repository at this point
Copy the full SHA f608e34View commit details
Commits on Jun 10, 2023
-
[consumer] Add rack-awareness (KIP-881) to assignors (#4252)
Co-authored-by: Emanuele Sabellico <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for 966b63d - Browse repository at this point
Copy the full SHA 966b63dView commit details
Commits on Jun 14, 2023
-
Avoid treating an OpenSSL error as a permanent error (#4294)
and treat unclean SSL closes as normal ones fixes #4293
Configuration menu - View commit details
-
Copy full SHA for 3e39a9e - Browse repository at this point
Copy the full SHA 3e39a9eView commit details -
Add broker reauthentication [KIP-368] (#4301)
Here's how we're doing the reauthentication: 1. In case we get a non-zero `session_lifetime_ms` in the SaslAuthenticate response for a broker `rkb`, start a timer for that broker at 90% of that. 2. [main thread] The timer is hit and the callback triggered. The callback enqueues an op on the broker `rkb`. 3. [broker thread] We get this op in `rd_kafka_broker_op_serve`, and we set max_inflight request to 1, and change the broker state into one of reauth. 4. [broker thread] When we encounter the reauth state in `rd_kafka_broker_thread_main`, we do some cleanup for the preexisting SASL state, and just do Auth exactly the same as the normal way (when we do it the first time around). This takes care of resetting max_inflight to the correct value, too. As the KIP and the discussion in #3754 points out, we can't send anything between the auth requests. Setting max_inflight to 1 means that only one request may be in flight, and since the Sasl* requests have a high priority in the queue (RD_KAFKA_PRIO_FLASH), they will actually hold the other requests back till authentication is complete. Setting it to 1 also means that any requests already in flight will await responses before the auth sequence starts. For OAUTHBEARER, the token itself has an expiry time. There are two cases here: 1. broker's connections.max.reauth.ms > time left to token's expiry: In this case, the session_lifetime_ms in the SaslAuthenticate response is set to the time left for the token's expiry. Since our OAUTHBEARER callback runs at 80% of (time left to token's expiry) and our reauth runs at 90% of (time left to token's expiry), we'll refresh the token before the reauth. It's somewhat trickier than that, because `next_token_refresh_time := client_time + 0.8*(token_expiry - client_time)` and `reauth_time := client_time + 0.9*session_lifetime_ms`. Since session_lifetime_ms is calculated on the server, it might have some drift between the clocks, as well as well as discount the time it takes for the communication between the client/server. But it's expected that even if `token_expiry - client_time != session_lifetime_ms`, the 0.8/0.9 factors will make up for it, as typical token refresh/re-authentication times are on the order of hours (and not seconds). 2. broker's connections.max.reauth.ms < time left to token's expiry: The broker returns connections.max.reauth.ms as the session_lifetime_ms. Since the token has a later expiry, we just use the same token to reauthenticate. --------- Co-authored-by: Victoria Wu <[email protected]> Co-authored-by: Emanuele Sabellico <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for 865cf60 - Browse repository at this point
Copy the full SHA 865cf60View commit details -
Update C standard requirements (#4169)
* Update C standard requirements * Test minimum C standard
Configuration menu - View commit details
-
Copy full SHA for 1d6fda8 - Browse repository at this point
Copy the full SHA 1d6fda8View commit details
Commits on Jun 15, 2023
-
Updated Magnus' Add 'fetch.queue.backoff.ms' to the consumer (#2879) …
…patch (#4284) this property allows to trade off cpu for memory by reducing fetch backoff, when values of `queued.max.messages.kbytes` and `queued.min.messages` have to be set too high to hold 1s of data. --------- Co-authored-by: Chris A. <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for e52aa3b - Browse repository at this point
Copy the full SHA e52aa3bView commit details
Commits on Jun 16, 2023
-
Fixed a bug where topic leader is not refreshed in the same metadata …
…call even if the broker is present. (#4315) Fixed a bug where topic leader is not refreshed in the same metadata call even if the broker is present.
Configuration menu - View commit details
-
Copy full SHA for 25da531 - Browse repository at this point
Copy the full SHA 25da531View commit details -
Configuration menu - View commit details
-
Copy full SHA for aa50e52 - Browse repository at this point
Copy the full SHA aa50e52View commit details
Commits on Jun 28, 2023
-
[mock]: Fix passing null pointer to strndup, which is UB (#4321)
UBSan diagnostic: librdkafka/override/src/rd.h:166:27: runtime error: null pointer passed as argument 1, which is declared to never be null Root cause: - rdkafka_mock_cgrp.c:570, `GroupInstanceId` is passed to `RD_KAFKAP_STR_DUP` while potentially NULL - l568, we have the check `if (GroupInstanceId)` which only checks whether the pointer is null (it can never be null based on construction). It does not check whether the string inside is null. - rdkafka_mock_handlers.c:1149, `GroupInstanceId` is set only if `rkbuf->rkbuf_reqhdr.ApiVersion >= 5`, otherwise it is NULL. Fix: - check `if (RD_KAFKAP_STR_LEN(GroupInstanceId))` instead Co-authored-by: Pierre Hallot <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for 2759b34 - Browse repository at this point
Copy the full SHA 2759b34View commit details
Commits on Jun 29, 2023
-
Update copyright notice of files changed (#4327)
with PRs started in 2023, global copyright notice, support email, github links
Configuration menu - View commit details
-
Copy full SHA for 49f05db - Browse repository at this point
Copy the full SHA 49f05dbView commit details
Commits on Jun 30, 2023
-
chore: update repo semaphore project (#4338)
Co-authored-by: Confluent Jenkins Bot <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for d174c0d - Browse repository at this point
Copy the full SHA d174c0dView commit details
Commits on Jul 7, 2023
-
Add KIP-235 implementation (#4292)
Add DNS alias support for secured connection, needed for Kerberos SASL authentication.
Configuration menu - View commit details
-
Copy full SHA for 961946e - Browse repository at this point
Copy the full SHA 961946eView commit details
Commits on Jul 10, 2023
-
Incremental alter configs implementation [KIP-339] (#4110)
requires broker version >= 2.3.0 --------- Co-authored-by: Emanuele Sabellico <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for 53a6a50 - Browse repository at this point
Copy the full SHA 53a6a50View commit details -
Scram Config API in Admin Client [KIP-554] (#4241)
requires broker version >= 2.7.0 --------- Co-authored-by: Emanuele Sabellico <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for c23adb9 - Browse repository at this point
Copy the full SHA c23adb9View commit details
Commits on Jul 12, 2023
-
Generates a random salt only when (#4350)
RAND_priv_bytes is available, since OpenSSL 1.1.1
Configuration menu - View commit details
-
Copy full SHA for e75de5b - Browse repository at this point
Copy the full SHA e75de5bView commit details
Commits on Jul 18, 2023
-
Configuration menu - View commit details
-
Copy full SHA for efc65e7 - Browse repository at this point
Copy the full SHA efc65e7View commit details
Commits on Jul 24, 2023
-
remove semaphore cache as it will not be available on public clusters (…
…#4347) * add debug * remove cache * increase timeout to 3h due to non-caching
Configuration menu - View commit details
-
Copy full SHA for c07a335 - Browse repository at this point
Copy the full SHA c07a335View commit details
Commits on Aug 7, 2023
-
Add Topic Id to Metadata Response (#4300)
* Added new data type UUID for topic id. * Added topic id support in Metadata Response.
Configuration menu - View commit details
-
Copy full SHA for 07262c4 - Browse repository at this point
Copy the full SHA 07262c4View commit details
Commits on Aug 14, 2023
-
Fix ListConsumerGroupOffsets not fetching offsets for all the topics …
…in a group with Apache Kafka version below 2.4.0. (#4346)
Configuration menu - View commit details
-
Copy full SHA for ff1aaf5 - Browse repository at this point
Copy the full SHA ff1aaf5View commit details
Commits on Aug 15, 2023
-
Configuration menu - View commit details
-
Copy full SHA for 49f180a - Browse repository at this point
Copy the full SHA 49f180aView commit details
Commits on Sep 21, 2023
-
Add destroy call when leader epoch is stale (#4429)
and partition is in state active
Configuration menu - View commit details
-
Copy full SHA for 1cb8009 - Browse repository at this point
Copy the full SHA 1cb8009View commit details
Commits on Sep 26, 2023
-
Fix segfault if assignor state is NULL, (#4381)
e.g. a destroy happens before the first assignment. Only affects the cooperative-sticky assignor
Configuration menu - View commit details
-
Copy full SHA for 73cf87c - Browse repository at this point
Copy the full SHA 73cf87cView commit details
Commits on Sep 27, 2023
-
[admin] KIP-430: Add authorized operations to describe API
commit bee8d6a80b81a8f31c823750e3e504537cd954ac Author: Milind L <[email protected]> Date: Wed Sep 27 11:40:35 2023 +0530 Squashed commit of the following: commit 73cf87c Author: Emanuele Sabellico <[email protected]> Date: Tue Sep 26 14:48:57 2023 +0200 Fix segfault if assignor state is NULL, (#4381) e.g. a destroy happens before the first assignment. Only affects the cooperative-sticky assignor commit 1cb8009 Author: Emanuele Sabellico <[email protected]> Date: Thu Sep 21 10:04:07 2023 +0200 Add destroy call when leader epoch is stale (#4429) and partition is in state active commit 49f180a Author: Pranav Rathi <[email protected]> Date: Tue Aug 15 23:47:28 2023 +0530 Added new environment variable to tests - TESTS_SKIP_BEFORE (#4317) commit ff1aaf5 Author: Pranav Rathi <[email protected]> Date: Mon Aug 14 18:31:48 2023 +0530 Fix ListConsumerGroupOffsets not fetching offsets for all the topics in a group with Apache Kafka version below 2.4.0. (#4346) commit f6f0a62 Author: Milind L <[email protected]> Date: Mon Sep 25 17:00:05 2023 +0530 Fix case where broker RPC might not contain authorized operations commit 63e0748 Author: Milind L <[email protected]> Date: Mon Sep 25 16:14:47 2023 +0530 Fix possible initialization issue commit 7205354 Author: Milind L <[email protected]> Date: Mon Sep 25 16:02:37 2023 +0530 Differentiate between 0 and unrequested authorized ops commit adc0c4f Author: Milind L <[email protected]> Date: Mon Sep 25 09:35:36 2023 +0530 Avoid malloc(0) commit 4257dc9 Author: Milind L <[email protected]> Date: Fri Sep 22 10:35:33 2023 +0530 Fix CI issues commit 0e05dea Author: Milind L <[email protected]> Date: Fri Sep 22 07:45:53 2023 +0530 Change TopicCollection create method name commit 74d98dc Author: Milind L <[email protected]> Date: Thu Sep 21 15:02:51 2023 +0530 Fix warning and add rack to cluster nodes commit fd14d24 Author: Milind L <[email protected]> Date: Fri Sep 15 12:38:56 2023 +0530 Retain topic ordering for DescribeTopics commit d90bb98 Author: Milind L <[email protected]> Date: Thu Sep 14 12:41:10 2023 +0530 Change rack_id to rack in Node public API commit 0233c0f Author: Milind L <[email protected]> Date: Wed Sep 6 15:50:37 2023 +0530 Fix typo in result type commit e6d4d63 Author: Milind L <[email protected]> Date: Mon Sep 4 17:26:44 2023 +0530 Add brokers_sorted to internal metadata commit 2c7f5e1 Author: Milind L <[email protected]> Date: Mon Sep 4 16:53:20 2023 +0530 Address comments: AuthorizedOperations_parse uses array commit 9a6ef10 Author: Milind L <[email protected]> Date: Mon Sep 4 15:47:41 2023 +0530 Address comments: cosmetic and copyright changes commit beccb0c Author: Milind L <[email protected]> Date: Mon Sep 4 15:10:54 2023 +0530 Address comments: Cosmetic changes commit 6239372 Author: Milind L <[email protected]> Date: Mon Sep 4 14:59:20 2023 +0530 Address comment and RD_IF_FREE fixes commit bdd8a4b Author: Milind L <[email protected]> Date: Mon Sep 4 14:55:26 2023 +0530 Fix style and refactor MetadataRequest into op/cb commit 53cd983 Author: Milind L <[email protected]> Date: Thu Aug 31 17:47:54 2023 +0530 Address DescribeCluster/DescribeConsumerGroup changes, fix memleak commit 59ab5bb Author: Milind L <[email protected]> Date: Thu Aug 31 13:57:51 2023 +0530 Address comments for DescribeTopics API commit 85f7f91 Author: Milind L <[email protected]> Date: Fri Aug 11 15:08:51 2023 +0530 Get rid of stray conflict marker commit bd7f5a7 Author: Milind L <[email protected]> Date: Wed Aug 9 19:27:39 2023 +0530 Style fixes commit ef3f480 Author: Milind L <[email protected]> Date: Wed Aug 9 19:26:48 2023 +0530 Fix examples commit 0ed7250 Merge: 61840ab 07262c4 Author: Milind L <[email protected]> Date: Wed Aug 9 14:08:09 2023 +0530 Merge branch 'master' into dev_kip430_cp_review_changes commit 61840ab Author: Milind L <[email protected]> Date: Wed Aug 9 13:53:33 2023 +0530 Address review comments: Part 2 commit 45780f8 Author: Milind L <[email protected]> Date: Wed Aug 9 10:13:23 2023 +0530 Address review comments: Part 1 commit 0bc97b3 Author: Milind L <[email protected]> Date: Wed Aug 2 11:31:37 2023 +0530 Break into functions, update Supported KIPS commit 6f8aa0d Author: Milind L <[email protected]> Date: Wed Aug 2 10:40:36 2023 +0530 Fix 0080 after addressing comments commit 8d8a473 Author: Milind L <[email protected]> Date: Tue Aug 1 19:59:39 2023 +0530 Address review comments: Refactor MetadataRequest into two parts commit 28615cd Author: Milind L <[email protected]> Date: Tue Aug 1 18:10:46 2023 +0530 Address review comments - Part 2 commit e01ad41 Author: Milind L <[email protected]> Date: Tue Aug 1 15:09:46 2023 +0530 Address review comments - Part 1 commit 3215a90 Author: Milind L <[email protected]> Date: Tue Aug 1 09:50:59 2023 +0530 Fixed changelog commit 4a4f503 Author: Milind L <[email protected]> Date: Mon Jul 31 20:41:57 2023 +0530 Remove fanout from DescribeTopics commit 9787d6c Merge: 8c2b4d4 c07a335 Author: Milind L <[email protected]> Date: Mon Jul 31 14:47:43 2023 +0530 Merge branch 'master' into dev_kip430_cp_review_changes commit 8c2b4d4 Author: Milind L <[email protected]> Date: Mon Jun 26 11:44:24 2023 +0530 Fix cluster_id allocation not on tmpabuf commit 4a4d9df Author: Milind L <[email protected]> Date: Mon Jun 26 11:29:26 2023 +0530 Revert to macro to fix msvc compilation commit 7fff6eb Merge: 3a9a340 aa50e52 Author: Milind L <[email protected]> Date: Mon Jun 26 11:18:39 2023 +0530 Remove warnings and add CHANGELOG commit 3a9a340 Author: Milind L <[email protected]> Date: Sat Jun 24 15:36:22 2023 +0530 Change API for common stuff commit 6ddbaba Merge: f497307 e52aa3b Author: Milind L <[email protected]> Date: Fri Jun 23 12:24:15 2023 +0530 Merge branch 'master' into dev_kip430_cp commit f497307 Author: Milind L <[email protected]> Date: Fri Jun 23 12:22:39 2023 +0530 Fix tests and change API to be similar to existing ones commit 3fec50a Author: Milind L <[email protected]> Date: Thu Jun 15 09:52:33 2023 +0530 Fix style and docs issues commit 99a368d Merge: 7c15746 865cf60 Author: Ruchir Jain <[email protected]> Date: Wed Jun 14 18:52:29 2023 +0530 Merge branch 'master' into dev_kip430_cp commit 7c15746 Author: jainruchir <[email protected]> Date: Wed Jun 14 18:49:32 2023 +0530 bug fix: request NULL, force_racks in MetadataReq commit 88707a0 Author: jainruchir <[email protected]> Date: Wed Jun 14 18:11:47 2023 +0530 bug fixes and include auth ops false default commit 060d694 Merge: 0e16f98 966b63d Author: jainruchir <[email protected]> Date: Wed Jun 14 15:54:10 2023 +0530 Merge 'master' of librdkafka into dev_kip430_cp commit 0e16f98 Author: jainruchir <[email protected]> Date: Tue Apr 11 10:04:40 2023 +0530 style-fix commit b9fea3c Author: jainruchir <[email protected]> Date: Tue Apr 11 09:33:57 2023 +0530 ClusterDescription destroy having double free bug removed commit 7d512bf Merge: 830d9b7 2c6dd0a Author: Ruchir Jain <[email protected]> Date: Tue Apr 11 09:32:39 2023 +0530 Merge branch 'master' into dev_kip430_cp commit 830d9b7 Author: jainruchir <[email protected]> Date: Thu Mar 30 14:36:25 2023 +0530 bug fix for adminoptions commit 0bfbf67 Author: jainruchir <[email protected]> Date: Fri Mar 17 16:05:22 2023 +0530 dev_KIP430 branch merged commit c28152a Author: jainruchir <[email protected]> Date: Fri Mar 17 15:05:36 2023 +0530 changes to describeCG tests commit d2c902b Author: jainruchir <[email protected]> Date: Tue Feb 21 15:55:50 2023 +0530 added test for include auth ops in 0081 initial commit commit 3a79ed6 Author: jainruchir <[email protected]> Date: Fri Feb 17 14:25:37 2023 +0530 KIP-430 initial changes without checking tests commit d0e2156 Author: jainruchir <[email protected]> Date: Fri Mar 17 10:01:08 2023 +0530 bug fix when include authorized ops is 0 desc Topics/Cluster commit a542f4d Author: jainruchir <[email protected]> Date: Wed Mar 15 10:25:40 2023 +0530 integration tests for describecluster commit 8df6f62 Author: jainruchir <[email protected]> Date: Tue Mar 14 14:04:44 2023 +0530 describe topics and cluster commit 069b8e8 Author: jainruchir <[email protected]> Date: Fri Feb 24 14:32:49 2023 +0530 include authorized topic/cluster ops initial draft
Configuration menu - View commit details
-
Copy full SHA for efbb966 - Browse repository at this point
Copy the full SHA efbb966View commit details -
Work around KIP-700 restrictions for DescribeCluster [KIP-430]
commit a92fe85 Merge: 2f38103 dfbacdc Author: Milind L <[email protected]> Date: Wed Sep 27 12:11:56 2023 +0530 Merge branch 'dev_kip430_cp_review_changes' into dev_kip430_cp_review_changes_describecluster_workaround commit 2f38103 Merge: 6a48697 73cf87c Author: Milind L <[email protected]> Date: Wed Sep 27 12:06:09 2023 +0530 Merge branch 'master' into dev_kip430_cp_review_changes_describecluster_workaround commit 6a48697 Merge: e90cf4d f6f0a62 Author: Milind L <[email protected]> Date: Tue Sep 26 11:45:37 2023 +0530 Merge branch 'dev_kip430_cp_review_changes' into dev_kip430_cp_review_changes_describecluster_workaround commit f6f0a62 Author: Milind L <[email protected]> Date: Mon Sep 25 17:00:05 2023 +0530 Fix case where broker RPC might not contain authorized operations commit e90cf4d Merge: 92e8185 63e0748 Author: Milind L <[email protected]> Date: Mon Sep 25 16:15:25 2023 +0530 Merge branch 'dev_kip430_cp_review_changes' into dev_kip430_cp_review_changes_describecluster_workaround commit 63e0748 Author: Milind L <[email protected]> Date: Mon Sep 25 16:14:47 2023 +0530 Fix possible initialization issue commit 92e8185 Merge: 1f47224 7205354 Author: Milind L <[email protected]> Date: Mon Sep 25 16:04:43 2023 +0530 Merge branch 'dev_kip430_cp_review_changes' into dev_kip430_cp_review_changes_describecluster_workaround commit 7205354 Author: Milind L <[email protected]> Date: Mon Sep 25 16:02:37 2023 +0530 Differentiate between 0 and unrequested authorized ops commit 1f47224 Merge: 6e4ab03 adc0c4f Author: Milind L <[email protected]> Date: Mon Sep 25 10:10:23 2023 +0530 Merge branch 'dev_kip430_cp_review_changes' into dev_kip430_cp_review_changes_describecluster_workaround commit adc0c4f Author: Milind L <[email protected]> Date: Mon Sep 25 09:35:36 2023 +0530 Avoid malloc(0) commit 6e4ab03 Merge: 9c20baa 4257dc9 Author: Milind L <[email protected]> Date: Fri Sep 22 10:35:49 2023 +0530 Merge branch 'dev_kip430_cp_review_changes' into dev_kip430_cp_review_changes_describecluster_workaround commit 4257dc9 Author: Milind L <[email protected]> Date: Fri Sep 22 10:35:33 2023 +0530 Fix CI issues commit 9c20baa Merge: 3145279 0e05dea Author: Milind L <[email protected]> Date: Fri Sep 22 07:48:00 2023 +0530 Merge branch 'dev_kip430_cp_review_changes' into dev_kip430_cp_review_changes_describecluster_workaround commit 0e05dea Author: Milind L <[email protected]> Date: Fri Sep 22 07:45:53 2023 +0530 Change TopicCollection create method name commit 74d98dc Author: Milind L <[email protected]> Date: Thu Sep 21 15:02:51 2023 +0530 Fix warning and add rack to cluster nodes commit fd14d24 Author: Milind L <[email protected]> Date: Fri Sep 15 12:38:56 2023 +0530 Retain topic ordering for DescribeTopics commit d90bb98 Author: Milind L <[email protected]> Date: Thu Sep 14 12:41:10 2023 +0530 Change rack_id to rack in Node public API commit 3145279 Merge: 7c1562b 0233c0f Author: Milind L <[email protected]> Date: Fri Sep 8 18:12:00 2023 +0530 Merge branch 'dev_kip430_cp_review_changes' into dev_kip430_cp_review_changes_describecluster_workaround commit 0233c0f Author: Milind L <[email protected]> Date: Wed Sep 6 15:50:37 2023 +0530 Fix typo in result type commit e6d4d63 Author: Milind L <[email protected]> Date: Mon Sep 4 17:26:44 2023 +0530 Add brokers_sorted to internal metadata commit 2c7f5e1 Author: Milind L <[email protected]> Date: Mon Sep 4 16:53:20 2023 +0530 Address comments: AuthorizedOperations_parse uses array commit 9a6ef10 Author: Milind L <[email protected]> Date: Mon Sep 4 15:47:41 2023 +0530 Address comments: cosmetic and copyright changes commit beccb0c Author: Milind L <[email protected]> Date: Mon Sep 4 15:10:54 2023 +0530 Address comments: Cosmetic changes commit 6239372 Author: Milind L <[email protected]> Date: Mon Sep 4 14:59:20 2023 +0530 Address comment and RD_IF_FREE fixes commit bdd8a4b Author: Milind L <[email protected]> Date: Mon Sep 4 14:55:26 2023 +0530 Fix style and refactor MetadataRequest into op/cb commit 53cd983 Author: Milind L <[email protected]> Date: Thu Aug 31 17:47:54 2023 +0530 Address DescribeCluster/DescribeConsumerGroup changes, fix memleak commit 59ab5bb Author: Milind L <[email protected]> Date: Thu Aug 31 13:57:51 2023 +0530 Address comments for DescribeTopics API commit 85f7f91 Author: Milind L <[email protected]> Date: Fri Aug 11 15:08:51 2023 +0530 Get rid of stray conflict marker commit 7c1562b Merge: 5104ef0 bd7f5a7 Author: Milind L <[email protected]> Date: Wed Aug 9 19:31:48 2023 +0530 Merge branch 'dev_kip430_cp_review_changes' into dev_kip430_cp_review_changes_describecluster_workaround commit bd7f5a7 Author: Milind L <[email protected]> Date: Wed Aug 9 19:27:39 2023 +0530 Style fixes commit 5104ef0 Author: Milind L <[email protected]> Date: Wed Aug 9 18:40:22 2023 +0530 Work around KIP-700 restrictions for DescribeCluster commit b231200 Author: Milind L <[email protected]> Date: Wed Aug 9 19:27:39 2023 +0530 Style fixes commit ef3f480 Author: Milind L <[email protected]> Date: Wed Aug 9 19:26:48 2023 +0530 Fix examples commit 0ed7250 Merge: 61840ab 07262c4 Author: Milind L <[email protected]> Date: Wed Aug 9 14:08:09 2023 +0530 Merge branch 'master' into dev_kip430_cp_review_changes commit 61840ab Author: Milind L <[email protected]> Date: Wed Aug 9 13:53:33 2023 +0530 Address review comments: Part 2 commit 45780f8 Author: Milind L <[email protected]> Date: Wed Aug 9 10:13:23 2023 +0530 Address review comments: Part 1 commit 0bc97b3 Author: Milind L <[email protected]> Date: Wed Aug 2 11:31:37 2023 +0530 Break into functions, update Supported KIPS commit 6f8aa0d Author: Milind L <[email protected]> Date: Wed Aug 2 10:40:36 2023 +0530 Fix 0080 after addressing comments commit 8d8a473 Author: Milind L <[email protected]> Date: Tue Aug 1 19:59:39 2023 +0530 Address review comments: Refactor MetadataRequest into two parts commit 28615cd Author: Milind L <[email protected]> Date: Tue Aug 1 18:10:46 2023 +0530 Address review comments - Part 2 commit e01ad41 Author: Milind L <[email protected]> Date: Tue Aug 1 15:09:46 2023 +0530 Address review comments - Part 1 commit 3215a90 Author: Milind L <[email protected]> Date: Tue Aug 1 09:50:59 2023 +0530 Fixed changelog commit 4a4f503 Author: Milind L <[email protected]> Date: Mon Jul 31 20:41:57 2023 +0530 Remove fanout from DescribeTopics commit 9787d6c Merge: 8c2b4d4 c07a335 Author: Milind L <[email protected]> Date: Mon Jul 31 14:47:43 2023 +0530 Merge branch 'master' into dev_kip430_cp_review_changes commit 8c2b4d4 Author: Milind L <[email protected]> Date: Mon Jun 26 11:44:24 2023 +0530 Fix cluster_id allocation not on tmpabuf commit 4a4d9df Author: Milind L <[email protected]> Date: Mon Jun 26 11:29:26 2023 +0530 Revert to macro to fix msvc compilation commit 7fff6eb Merge: 3a9a340 aa50e52 Author: Milind L <[email protected]> Date: Mon Jun 26 11:18:39 2023 +0530 Remove warnings and add CHANGELOG commit 3a9a340 Author: Milind L <[email protected]> Date: Sat Jun 24 15:36:22 2023 +0530 Change API for common stuff commit 6ddbaba Merge: f497307 e52aa3b Author: Milind L <[email protected]> Date: Fri Jun 23 12:24:15 2023 +0530 Merge branch 'master' into dev_kip430_cp commit f497307 Author: Milind L <[email protected]> Date: Fri Jun 23 12:22:39 2023 +0530 Fix tests and change API to be similar to existing ones commit 3fec50a Author: Milind L <[email protected]> Date: Thu Jun 15 09:52:33 2023 +0530 Fix style and docs issues commit 99a368d Merge: 7c15746 865cf60 Author: Ruchir Jain <[email protected]> Date: Wed Jun 14 18:52:29 2023 +0530 Merge branch 'master' into dev_kip430_cp commit 7c15746 Author: jainruchir <[email protected]> Date: Wed Jun 14 18:49:32 2023 +0530 bug fix: request NULL, force_racks in MetadataReq commit 88707a0 Author: jainruchir <[email protected]> Date: Wed Jun 14 18:11:47 2023 +0530 bug fixes and include auth ops false default commit 060d694 Merge: 0e16f98 966b63d Author: jainruchir <[email protected]> Date: Wed Jun 14 15:54:10 2023 +0530 Merge 'master' of librdkafka into dev_kip430_cp commit 0e16f98 Author: jainruchir <[email protected]> Date: Tue Apr 11 10:04:40 2023 +0530 style-fix commit b9fea3c Author: jainruchir <[email protected]> Date: Tue Apr 11 09:33:57 2023 +0530 ClusterDescription destroy having double free bug removed commit 7d512bf Merge: 830d9b7 2c6dd0a Author: Ruchir Jain <[email protected]> Date: Tue Apr 11 09:32:39 2023 +0530 Merge branch 'master' into dev_kip430_cp commit 830d9b7 Author: jainruchir <[email protected]> Date: Thu Mar 30 14:36:25 2023 +0530 bug fix for adminoptions commit 0bfbf67 Author: jainruchir <[email protected]> Date: Fri Mar 17 16:05:22 2023 +0530 dev_KIP430 branch merged commit c28152a Author: jainruchir <[email protected]> Date: Fri Mar 17 15:05:36 2023 +0530 changes to describeCG tests commit d2c902b Author: jainruchir <[email protected]> Date: Tue Feb 21 15:55:50 2023 +0530 added test for include auth ops in 0081 initial commit commit 3a79ed6 Author: jainruchir <[email protected]> Date: Fri Feb 17 14:25:37 2023 +0530 KIP-430 initial changes without checking tests commit d0e2156 Author: jainruchir <[email protected]> Date: Fri Mar 17 10:01:08 2023 +0530 bug fix when include authorized ops is 0 desc Topics/Cluster commit a542f4d Author: jainruchir <[email protected]> Date: Wed Mar 15 10:25:40 2023 +0530 integration tests for describecluster commit 8df6f62 Author: jainruchir <[email protected]> Date: Tue Mar 14 14:04:44 2023 +0530 describe topics and cluster commit 069b8e8 Author: jainruchir <[email protected]> Date: Fri Feb 24 14:32:49 2023 +0530 include authorized topic/cluster ops initial draft
Configuration menu - View commit details
-
Copy full SHA for 32747f5 - Browse repository at this point
Copy the full SHA 32747f5View commit details
Commits on Sep 28, 2023
-
Configuration menu - View commit details
-
Copy full SHA for cca5e75 - Browse repository at this point
Copy the full SHA cca5e75View commit details
Commits on Sep 29, 2023
-
Add leader epoch to control messages (#4434)
Add leader epoch to control messages to make sure they're stored for committing even without a subsequent fetch message
Configuration menu - View commit details
-
Copy full SHA for 9be261b - Browse repository at this point
Copy the full SHA 9be261bView commit details -
Configuration menu - View commit details
-
Copy full SHA for 116b6cf - Browse repository at this point
Copy the full SHA 116b6cfView commit details -
Configuration menu - View commit details
-
Copy full SHA for 788cd0c - Browse repository at this point
Copy the full SHA 788cd0cView commit details -
Increased flexver request size for Metadata request to include topic_…
…id size (#4453) Co-authored-by: Emanuele Sabellico <[email protected]> Co-authored-by: Milind L <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for bd2afcf - Browse repository at this point
Copy the full SHA bd2afcfView commit details -
Configuration menu - View commit details
-
Copy full SHA for e2d79e1 - Browse repository at this point
Copy the full SHA e2d79e1View commit details -
Configuration menu - View commit details
-
Copy full SHA for ba57a12 - Browse repository at this point
Copy the full SHA ba57a12View commit details -
[KIP-580] Exponential Backoff with Mock Broker Changes to Automate Te…
…sting. (#4422) * Rebase Commit * Changes for Partial Comments * Changes * Run style fix * Windows build fix for 0143 * Changes * Changes * Changes * Style fixes --------- Co-authored-by: Milind L <[email protected]> Co-authored-by: Milind L <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for 6dc7c71 - Browse repository at this point
Copy the full SHA 6dc7c71View commit details -
Move can_q_contain_fetched_msgs inside q_serve (#4431)
to be able to correctly reset polled flag when the forwarded queue doesn't contain messages but the destination queue does, and application is polling from the forwarded queue. Co-authored-by: Milind L <[email protected]> Co-authored-by: Milind L <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for 7ebc19a - Browse repository at this point
Copy the full SHA 7ebc19aView commit details -
Fix for idempotent producer fatal errors, triggered after a possibly …
…persisted message state (#4438)
Configuration menu - View commit details
-
Copy full SHA for 0fd8e30 - Browse repository at this point
Copy the full SHA 0fd8e30View commit details -
Configuration menu - View commit details
-
Copy full SHA for be353be - Browse repository at this point
Copy the full SHA be353beView commit details
Commits on Oct 11, 2023
-
Fix public API for mock requests (#4458)
* Fix public API for mock requests * Address review comments
Configuration menu - View commit details
-
Copy full SHA for f64242d - Browse repository at this point
Copy the full SHA f64242dView commit details -
Configuration menu - View commit details
-
Copy full SHA for 35df9d6 - Browse repository at this point
Copy the full SHA 35df9d6View commit details
Commits on Oct 16, 2023
-
Added topic id to describe_topic response. (#4451)
--------- Co-authored-by: mahajanadhitya <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for 59f3ea3 - Browse repository at this point
Copy the full SHA 59f3ea3View commit details
Commits on Oct 17, 2023
-
[KIP-396] Complete implementation with ListOffsets (#4225)
contains a fix for `rd_kafka_query_watermark_offsets` too, to clear metadata cache for a queried partition if leader changes. --------- Co-authored-by: Emanuele Sabellico <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for 99c67d3 - Browse repository at this point
Copy the full SHA 99c67d3View commit details
Commits on Oct 20, 2023
-
Configuration menu - View commit details
-
Copy full SHA for da21e05 - Browse repository at this point
Copy the full SHA da21e05View commit details
Commits on Oct 23, 2023
-
Configuration menu - View commit details
-
Copy full SHA for af11adc - Browse repository at this point
Copy the full SHA af11adcView commit details
Commits on Oct 24, 2023
-
Fix calls with empty list (#4480)
DescribeTopics and ListOffsets should return an empty array if and empty array is passed as parameter. Consistent with Java and user friendly for users using filter and map.
Configuration menu - View commit details
-
Copy full SHA for 95a542c - Browse repository at this point
Copy the full SHA 95a542cView commit details
Commits on Dec 8, 2023
-
Configuration menu - View commit details
-
Copy full SHA for df6efd2 - Browse repository at this point
Copy the full SHA df6efd2View commit details
Commits on Dec 13, 2023
-
Configuration menu - View commit details
-
Copy full SHA for 22cdb64 - Browse repository at this point
Copy the full SHA 22cdb64View commit details
Commits on Dec 14, 2023
-
[KIP-848] topic_id in topic_partition_internal, some new error codes (#…
…4404) * KIP-848 new error codes (partial) * Add topic id to topic_partition_private * Rename rd_kafka_uuid_t to rd_kafka_Uuid_t * [KIP-848] Added new configs group.protocol and group.remote.assignor (#4414) Added new configs group.protocol and group.remote.assignor * [KIP-848] Added topic id to topic_partition_t while reading from buffer (#4416) * Address comments * Address comment * Upgrade vcpkg --------- Co-authored-by: Pranav Rathi <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for 42cc318 - Browse repository at this point
Copy the full SHA 42cc318View commit details -
Configuration menu - View commit details
-
Copy full SHA for 7632311 - Browse repository at this point
Copy the full SHA 7632311View commit details -
Make install dependent on libs to avoid errors (#4562)
Make install dependent on libs to avoid errors with parallelism. Don't use passed libdir for librdkafka static dependencies built from source
Configuration menu - View commit details
-
Copy full SHA for e03d3bb - Browse repository at this point
Copy the full SHA e03d3bbView commit details
Commits on Jan 23, 2024
-
Bump openssl version partially to 3.0.12 (#4586)
* Bump openssl version partially to 3.0.12 We will stick to 3.0.x with this PR (LTS version) vcpkg doesn't yet have anything greater than 3.0.8, so this is only a partial upgrade. * Update CHANGELOG.md Co-authored-by: Emanuele Sabellico <[email protected]> * Update CHANGELOG.md Co-authored-by: Emanuele Sabellico <[email protected]> --------- Co-authored-by: Emanuele Sabellico <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for 2dff2eb - Browse repository at this point
Copy the full SHA 2dff2ebView commit details
Commits on Feb 9, 2024
-
Uniform test code across scripts and KRaft mode (#4524)
Include new trivup patch version in librdkafka
Configuration menu - View commit details
-
Copy full SHA for 6d88efd - Browse repository at this point
Copy the full SHA 6d88efdView commit details
Commits on Feb 13, 2024
-
Uuid support in mock cluster (#4591)
also adds the possibility to generate pseudo-random Uuids
Configuration menu - View commit details
-
Copy full SHA for a6d85bd - Browse repository at this point
Copy the full SHA a6d85bdView commit details
Commits on Mar 12, 2024
-
Fix BoringSSL by supplying string length to `X509_VERIFY_PARAM_set1_h…
…ost` explicitly (#4513) * Fix BoringSSL by supplying string length to X509_VERIFY_PARAM_set1_host explicitly * Style fix stip docker login if secret isn't available --------- Co-authored-by: Emanuele Sabellico <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for e305e0c - Browse repository at this point
Copy the full SHA e305e0cView commit details
Commits on Mar 14, 2024
-
integration tests can be started in KRaft mode and run against any GitHub Kafka branch other than the released versions
Configuration menu - View commit details
-
Copy full SHA for 91a423a - Browse repository at this point
Copy the full SHA 91a423aView commit details
Commits on Mar 18, 2024
-
Configuration menu - View commit details
-
Copy full SHA for 267367c - Browse repository at this point
Copy the full SHA 267367cView commit details
Commits on Apr 4, 2024
-
Fix pipeline inclusion of static binaries (#4666)
without gssapi dependency
Configuration menu - View commit details
-
Copy full SHA for a6c8cec - Browse repository at this point
Copy the full SHA a6c8cecView commit details
Commits on Apr 5, 2024
-
Fix to main loop timeout calculation (#4671)
leading to a tight loop for a max period of 1 ms When the main thread loop was awakened less than 1 ms before the expiration of a timeout, it was serving with a zero timeout, leading to increased CPU usage until the timeout was reached. Happening since 1.x
Configuration menu - View commit details
-
Copy full SHA for 807b23a - Browse repository at this point
Copy the full SHA 807b23aView commit details
Commits on Apr 10, 2024
-
Fix duplicate messages when resuming partitions not paused (#4636)
In case of subscription change with a consumer using the cooperative assignor it could resume fetching from a previous position. That could also happen if resuming a partition that wasn't paused. Fixed by ensuring that a resume operation is completely a no-op when the partition isn't paused
Configuration menu - View commit details
-
Copy full SHA for 5b798cd - Browse repository at this point
Copy the full SHA 5b798cdView commit details
Commits on Apr 15, 2024
-
[KIP-467] records that cause the whole batch to be dropped
bumped produce API to v8. Added support for record_errors and error_msg fields. Made RD_KAFKA_RESP_ERR_INVALID_MSG retriable. --------- Co-authored-by: Emanuele Sabellico <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for 8532a0e - Browse repository at this point
Copy the full SHA 8532a0eView commit details
Commits on Apr 18, 2024
-
[KIP-848] Added ConsumerGroupHeartbeat API request
and response with basic cgrp_consumer flow - Added topic id to topic_partition_t while reading from buffer - Added new methods and way to add topic_id to topic partition private - Added new configs group.protocol and group.remote.assignor - Added ConsumerGroupHeartbeat API Request Contract - Added ConsumerGroupApi Request without handling different cases - Working ConsumerGroupHeartbeat API with proper response - Properly receiving assigned partitions with topic_id from the Response - Added metadata request as well after parsing the response. Separate it out from to the topic partition branch - Added metadata response flow with rko - Updated OffsetFetch to v9 - Removed unrequred fields from ConsumerGroupHeartbeat API to make it work with AK > 3.6 - OffsetFetch working fine. Able to consume. - Changed subsribed list to use correct field - Fixed few memory leaks - Some more memory leak fixes. Added updation to subscribed topics list - Minor changes - [KIP-848] Added new configs group.protocol and group.remote.assignor (#4414) - Added new configs group.protocol and group.remote.assignor - Removed printfs and Updated hardcoded one topic for metadata request - Removed some changes related to removed changes in the protocols - [KIP-848] Added topic id to topic_partition_t while reading from buffer (#4416) - Updating topic name from metadata response for all the requested topic_ids instead of just 1. - Style fixes and fixed skip tag issue in buf_*_topic_partition - Changed variable for next assignment - Added topic name while reading topic partition buffer - Changed variable name from assignments to assignment
Configuration menu - View commit details
-
Copy full SHA for 2089325 - Browse repository at this point
Copy the full SHA 2089325View commit details -
[KIP-848] Assign, revoke, leave group flows
- Rebased with master - WIP: assignment, revocation, leave group flow - Remove print statements - Remove print statement left - Separate rd_kafka_cgrp_consumer_assignment_done - Allow changing subscription to empty - Expedite next heartbeat - Static group membership and max poll interval checks - Expedite next heartbeat - Fix existing protocol - Partial implementation of reconciliation and next assignment handling - Uniform tests handling across scripts and KRaft mode - Run tests with group.protocol=consumer and reusable condition to skip mock cluster - Test 0113 partial - Test 0018 - Test 0113 stickyness - Test 0113 complete except regex subscription and u_multiple_subscription_changes(true) - Skip some tests, fix subscription change - Test 0029 exclusion clarified - Debug statements - Introduce current assignment rename rkcg_current_target_assignments to rkcg_target_assignment rename rkcg_next_target_assignments to rkcg_next_target_assignment - change to ConsumerGroupHeartbeat in logs - Add remote assignor to debug log - Fix rd_kafka_buf_write_topic_partitions not using topic ids for comparison
Configuration menu - View commit details
-
Copy full SHA for 0c545a5 - Browse repository at this point
Copy the full SHA 0c545a5View commit details -
[KIP-848] HB Error Code, Partial ack flow, OffsetCommit Request, Resp…
…onse and various fixes (#4634) - Added error handling to ConsumerGroupHeartbeat API - Added type new errors - UNRELEASED_INSTANCE_ID and UNSUPPORTED_ASSIGNOR - Added partial acknowledgement flow - Upgraded OffsetCommit Request and response to v9 - Fixed metadata being called with duplicate topic id - Fixed next_target_assignment not getting reset to NULL - Fixed member stuck if fenced during rebalancing - Fixed segfault with current and target assignment while resetting consumer group - Fixed segfault due to deleted topic in metadata - Fixed leave not being called if the consumer without any assignment leaves
Configuration menu - View commit details
-
Copy full SHA for 1c5228c - Browse repository at this point
Copy the full SHA 1c5228cView commit details -
Metadata cache by topic id (#4676)
improve documentation of Metadata functions
Configuration menu - View commit details
-
Copy full SHA for b3a36f2 - Browse repository at this point
Copy the full SHA b3a36f2View commit details -
Fix to metadata cache expiration on full metadata refresh (#4677)
Metadata cache was cleared on full metadata refresh, leading to unnecessary refreshes and occasional `UNKNOWN_TOPIC_OR_PART` errors. Solved by updating cache for existing or hinted entries instead of clearing them. Happening since 2.1.0
Configuration menu - View commit details
-
Copy full SHA for 845aa9b - Browse repository at this point
Copy the full SHA 845aa9bView commit details -
Fix for a wrong error returned on full metadata refresh before joinin…
…g a consumer group (#4678) A metadata call before member joins consumer group, could lead to an `UNKNOWN_TOPIC_OR_PART` error. Solved by updating the consumer group following a metadata refresh only in safe states. Happening since 2.1.0
Configuration menu - View commit details
-
Copy full SHA for d2ddd52 - Browse repository at this point
Copy the full SHA d2ddd52View commit details -
Fix to metadata refresh interruption (#4679)
Metadata refreshes without partition leader change could lead to a loop of metadata calls at fixed intervals. Solved by stopping metadata refresh when all existing metadata is non-stale. Happening since 2.3.0
Configuration menu - View commit details
-
Copy full SHA for 194fb5d - Browse repository at this point
Copy the full SHA 194fb5dView commit details -
[KIP-848] Use metadata cache by topic id, fixes and improvements (#4661)
- rename 'generic' protocol to 'classic' - consumer group serve timer to awake the loop earlier - compare and find into topic partition list by topic id only - fix memory leak when instance creation fails and app_conf is provided - fix cases where HB response is received after unsubscription - use topic name from current assignment if it's missing from metadata - expedite heartbeat simplification and fixes to next interval check and to the place where number of retries is increased - expedite HB after changing state back to INIT - use the CONSUMER_F_WAIT_REJOIN to trigger the rejoin instead of calling it from max poll interval timer - schedule timer for next execution reschedule it if expected earlier expedite through scheduling cgrp serve timer - treat unsupported feature error as fatal - avoid removing partitions not matched by a new subscription immediately, for a possible desynchronization with the coordinator, with said partitions not being consumed anymore
Configuration menu - View commit details
-
Copy full SHA for b42d0d9 - Browse repository at this point
Copy the full SHA b42d0d9View commit details -
[KIP-848] Added new error code handling to OffsetCommit and OffsetFet…
…ch (#4681) - Added new errors to manual commit. - improvements to OffsetCommit and OffsetFetch error code handling.
Configuration menu - View commit details
-
Copy full SHA for 0f0d8d8 - Browse repository at this point
Copy the full SHA 0f0d8d8View commit details -
[KIP-848] Fix reading error code in CGH_leave due to incorrect parsin…
…g of the response. (#4691)
Configuration menu - View commit details
-
Copy full SHA for 8a6b446 - Browse repository at this point
Copy the full SHA 8a6b446View commit details -
Fix for an undesired partition migration with stale leader epoch (#4680)
A partition migration could happen, using stale metadata, when the partition was undergoing a validation and being retried because of an error. Solved by doing a partition migration only with a non-stale leader epoch. Happening since 2.1.0
Configuration menu - View commit details
-
Copy full SHA for 6584ed7 - Browse repository at this point
Copy the full SHA 6584ed7View commit details -
Configuration menu - View commit details
-
Copy full SHA for 0036e0c - Browse repository at this point
Copy the full SHA 0036e0cView commit details -
Configuration menu - View commit details
-
Copy full SHA for becc3ad - Browse repository at this point
Copy the full SHA becc3adView commit details -
Fix hang in incremental assign during close (#4528)
While using the cooperative assignor, given an assignment is received while closing the consumer it's possible that it gets stuck in state WAIT_ASSIGN_CALL, while the method is converted to a full unassign. Solved by changing state from WAIT_ASSIGN_CALL to WAIT_UNASSIGN_CALL while doing this conversion. Closes #4527
Configuration menu - View commit details
-
Copy full SHA for dd1e72d - Browse repository at this point
Copy the full SHA dd1e72dView commit details -
Configuration menu - View commit details
-
Copy full SHA for c96878a - Browse repository at this point
Copy the full SHA c96878aView commit details
Commits on Apr 23, 2024
-
Fix flaky test because of consume returning before the timeout (#4695)
C++ version fix Add space in warning
Configuration menu - View commit details
-
Copy full SHA for a5c5641 - Browse repository at this point
Copy the full SHA a5c5641View commit details
Commits on May 7, 2024
-
Configuration menu - View commit details
-
Copy full SHA for 18bc849 - Browse repository at this point
Copy the full SHA 18bc849View commit details -
Configuration menu - View commit details
-
Copy full SHA for a4bf487 - Browse repository at this point
Copy the full SHA a4bf487View commit details
Commits on May 8, 2024
-
Change retry.backoff.* to apply to both producer and consumer (#4561)
* Change retry.backoff.* to apply to both producer and consumer * Style fixes
Configuration menu - View commit details
-
Copy full SHA for 2587cac - Browse repository at this point
Copy the full SHA 2587cacView commit details
Commits on May 31, 2024
-
Configuration menu - View commit details
-
Copy full SHA for 465f81c - Browse repository at this point
Copy the full SHA 465f81cView commit details
Commits on Jun 6, 2024
-
Mock handlers: Metadata handler upgrade to version 12 (#4735)
* Metadata handler upgrade to version 12 and offset leader epoch fix in ListOffsets * Fixed tag for alpine and manylinux images * Update msys2 installer and fix for missing CURL_LIBRARIES * Fix request by topic name when topic id is available
Configuration menu - View commit details
-
Copy full SHA for 1082405 - Browse repository at this point
Copy the full SHA 1082405View commit details -
Add files for lz4 1.9.4 (#4726)
* Add files for lz4 1.9.4 * Update changelog.md * rdxxhash should not be in clang-format list * Add instructions and update memory alloc/free * Update instructions for lz4
Configuration menu - View commit details
-
Copy full SHA for 2fe647b - Browse repository at this point
Copy the full SHA 2fe647bView commit details
Commits on Jun 7, 2024
-
Update CODEOWNERS to be only clients (#4746)
Remove kafka-eng as it's too wide.
Configuration menu - View commit details
-
Copy full SHA for 810872d - Browse repository at this point
Copy the full SHA 810872dView commit details
Commits on Jun 11, 2024
-
Handle overflow in rd_buf_write_remains (#4689)
Fixes a segfault when a segment is erased and more data is written to the buffer.
Configuration menu - View commit details
-
Copy full SHA for 8242cc9 - Browse repository at this point
Copy the full SHA 8242cc9View commit details -
Add a warning in client.dns.lookup documentation (#4733)
`resolve_canonical_bootstrap_servers_only` must only be used with Kerberos
Configuration menu - View commit details
-
Copy full SHA for 47d7c01 - Browse repository at this point
Copy the full SHA 47d7c01View commit details
Commits on Jun 12, 2024
-
Fix for an idempotent producer error, with a message batch not recons…
…tructed identically when retried (#4750) Issues: #4736 Fix for an idempotent producer error, with a message batch not reconstructed identically when retried. Caused the error message "Local: Inconsistent state: Unable to reconstruct MessageSet". Happening on large batches. Solved by using the same backoff baseline for all messages in the batch. Happens since 2.2.0
Configuration menu - View commit details
-
Copy full SHA for e2265b6 - Browse repository at this point
Copy the full SHA e2265b6View commit details -
[KIP-951] Fetch RPC prework: upgrade to v15 (#4584)
- Style fix - RPC version update - Fix uninitialized value and topic name from rkt - Revert newline changes - Remove duplicate declaration - Rename rd_kafka_buf_write_tags to rd_kafka_buf_write_tags_empty before implementing the define that allows to write tags - Upgrade fetch mock handler to v15 - devel assertion and logging improvements Co-authored-by: Emanuele Sabellico <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for 6867b9f - Browse repository at this point
Copy the full SHA 6867b9fView commit details
Commits on Jun 13, 2024
-
Produce upgrade to flexver (#4595)
client mock cluster implementation --------- Co-authored-by: Emanuele Sabellico <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for 6b13a7b - Browse repository at this point
Copy the full SHA 6b13a7bView commit details
Commits on Jun 14, 2024
-
[KIP-951] Common functions for reading and writing tags
and for tags common to Fetch and Produce in KIP-951 --------- Co-authored-by: mahajanadhitya <[email protected]> Co-authored-by: Emanuele Sabellico <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for 6db3c03 - Browse repository at this point
Copy the full SHA 6db3c03View commit details -
NONJAVACLI-3460: update dependencies (#4706)
* update third party dependencies * update lz4 version in the header file * update libraries for the windows build * reverting the version bump in the headers * use the latest version of curl * Update OpenSSL and add CHANGELOG.md * downgade curl version to one available via vcpkg * downgrade zlib to last available version in vcpkg * downgrade zstd to the latest available * Include CPPFLAGS within make for libcurl * Update mklove/modules/configure.libcurl * Update CHANGELOG.md --------- Co-authored-by: Milind L <[email protected]> Co-authored-by: Emanuele Sabellico <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for c526073 - Browse repository at this point
Copy the full SHA c526073View commit details
Commits on Jun 17, 2024
-
[KIP-951] Leader discovery optimizations for the client (#4756)
contains the code changes to trigger a metadata update when the corresponding tags are received by the broker for partitions that have changed leadership, during Fetch or Produce requests.
Configuration menu - View commit details
-
Copy full SHA for f47815b - Browse repository at this point
Copy the full SHA f47815bView commit details -
Configuration menu - View commit details
-
Copy full SHA for 0e3128c - Browse repository at this point
Copy the full SHA 0e3128cView commit details
Commits on Jun 21, 2024
-
[KIP-951] Tests and documentation (#4767)
* Add test and mock files * Remove unnecessary semicolons * Review comments: * Fix to reduce flakyness of test 0146/do_test_stale_metadata_doesnt_migrate_partition * CHANGELOG and INTRODUCTION documentation --------- Co-authored-by: Anchit Jain <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for bb2843b - Browse repository at this point
Copy the full SHA bb2843bView commit details
Commits on Jun 26, 2024
-
Add -lrt while building zstd for centos (#4769)
Later versions of zstd fail without -lrt, see facebook/zstd#3558 .
Configuration menu - View commit details
-
Copy full SHA for bef137a - Browse repository at this point
Copy the full SHA bef137aView commit details
Commits on Jul 5, 2024
-
Remove CentOS 6 and CentOS 7 binaries (#4775)
*Remove CentOS 6 and 7 support as discontinued, keeps using manylinux_2_28 based on AlmaLinux 8 (CentOS 8) * Remove fix for CentOS 6 * Add CHANGELOG entry * Upgrade test and verify package creation or installation using clients repository
Configuration menu - View commit details
-
Copy full SHA for 847bae1 - Browse repository at this point
Copy the full SHA 847bae1View commit details
Commits on Jul 8, 2024
-
KIP 714 with compression support (#4721)
KIP 714 with compression support (#4721) implemented GetTelemetrySubscriptions and PushTelemetry to send client telemetry to the requesting broker. Available metrics: * producer.connection.creation.rate * producer.connection.creation.total * producer.node.request.latency.avg * producer.node.request.latency.max * producer.produce.throttle.time.avg * producer.produce.throttle.time.max * producer.record.queue.time.avg * producer.record.queue.time.max * consumer.connection.creation.rate * consumer.connection.creation.total * consumer.node.request.latency.avg * consumer.node.request.latency.max * consumer.coordinator.assigned.partitions Compression is supported with zstd, zlib, lz4, or snappy. --------- Co-authored-by: Milind L <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for 6eaf89f - Browse repository at this point
Copy the full SHA 6eaf89fView commit details
Commits on Aug 5, 2024
-
Add forward declaration to fix compilation without ssl (#4794)
and add build checks with different configurations
Configuration menu - View commit details
-
Copy full SHA for d72576a - Browse repository at this point
Copy the full SHA d72576aView commit details
Commits on Aug 30, 2024
-
Fix an assert being triggered when no metrics matched on the client s…
…ide during send push telemetry call (#4826)
Configuration menu - View commit details
-
Copy full SHA for 9416dd8 - Browse repository at this point
Copy the full SHA 9416dd8View commit details
Commits on Sep 24, 2024
-
fallback happens when any topic to fetch has a zero topic id, that can happen if the cluster has a Fetch version that is greater or equal to 13 but an inter broker protocol version that is less than 2.8
Configuration menu - View commit details
-
Copy full SHA for 7f63d82 - Browse repository at this point
Copy the full SHA 7f63d82View commit details -
Configuration menu - View commit details
-
Copy full SHA for f55f3ec - Browse repository at this point
Copy the full SHA f55f3ecView commit details
Commits on Oct 3, 2024
-
[KIP-714] Additional consumer metrics (#4808)
add missing consumer metrics described in the KIP: * consumer.coordinator.rebalance.latency.avg * consumer.coordinator.rebalance.latency.max * consumer.coordinator.rebalance.latency.total * consumer.fetch.manager.fetch.latency.avg * consumer.fetch.manager.fetch.latency.max * consumer.poll.idle.ratio.avg * consumer.coordinator.commit.latency.avg * consumer.coordinator.commit.latency.max additionally: * add unit tests for all the metrics * add integrations tests with the producer or consumer while they're active * configurable group initial rebalance delay ms to make integration tests reusable with both producer and consumer --------- Co-authored-by: mahajanadhitya <[email protected]> Co-authored-by: Anchit Jain <[email protected]> Co-authored-by: Emanuele Sabellico <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for d5e1f9f - Browse repository at this point
Copy the full SHA d5e1f9fView commit details -
Produce request latency metrics and more tests (#4847)
also fix macOS build issue --------- Co-authored-by: Emanuele Sabellico <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for 77622e2 - Browse repository at this point
Copy the full SHA 77622e2View commit details
Commits on Oct 4, 2024
-
[KIP-848] ListGroups filter to list only given group types (#4860)
Co-authored-by: mahajanadhitya <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for 25db856 - Browse repository at this point
Copy the full SHA 25db856View commit details
Commits on Oct 9, 2024
-
Added Public API for Preferred/Unclean Leader Election on Topic Parti…
…tions (#4845) * electLeaders Api 1st draft * Minor change * Elect Leaders API final * minor change * Added a function * Minor Change * removed binary file from pr * Style fix * Resolve documentation errors * resolved build errors * first round of comments * name fixes * second round of comments * memory deallocation fix * Changelog changes addition * changes * variable naming change * third round comments * grammar change * latest changes * additional formatting * documentation changes * additional comments * one more round comments * election type count * name change election type cnt * new comments * removing election type check * removing merge conflicts * changelog.md changes * new changes * Fixing failing tests * Moved top level error code from response to event * changed topic partition result structure * style fix * remove null partitions check * requested changes * introduction md formatting * requested changes * partitions cnt print --------- Co-authored-by: Pranav Rathi <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for 0cd23c6 - Browse repository at this point
Copy the full SHA 0cd23c6View commit details -
Adding int identifier for transactional ID (#4856)
Co-authored-by: John "Preston" Mille <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for 54480ef - Browse repository at this point
Copy the full SHA 54480efView commit details -
[KIP-460] Remove duplicate ElectLeaders result type (#4867)
from external API and avoid exposing internal destructor
Configuration menu - View commit details
-
Copy full SHA for 7fc5a59 - Browse repository at this point
Copy the full SHA 7fc5a59View commit details
Commits on Oct 16, 2024
-
Fix for a Fetch regression when connecting to Apache Kafka < 2.7 (#4871)
AK 2.7 is the first version implementing Fetch 12, before that it shouldn't fallback to v12, neither check if topic IDs are supported.
Configuration menu - View commit details
-
Copy full SHA for c23b2a6 - Browse repository at this point
Copy the full SHA c23b2a6View commit details -
Fix for an infinite loop in cooperative sticky assignor (#4800)
when potential topic partitions are less than number of members.
Configuration menu - View commit details
-
Copy full SHA for 3b68a0c - Browse repository at this point
Copy the full SHA 3b68a0cView commit details -
Configuration menu - View commit details
-
Copy full SHA for 88604ca - Browse repository at this point
Copy the full SHA 88604caView commit details
Commits on Oct 18, 2024
-
ListOffsetsRequest should only be sent to the leader replica (CI) (#4754
) as replicas reply with "NOT_LEADER_OR_FOLLOWER" when using the replica id, Java clients sends requests to the leader too. Co-authored-by: Kyle Phelps <[email protected]>
Configuration menu - View commit details
-
Copy full SHA for 2810e5c - Browse repository at this point
Copy the full SHA 2810e5cView commit details