From c8deedab78cf45df70edb6ad8ee85fff6e888511 Mon Sep 17 00:00:00 2001
From: "dependabot[bot]" <49699333+dependabot[bot]@users.noreply.github.com>
Date: Fri, 7 Jul 2023 22:16:53 +0000
Subject: [PATCH] chore(deps): Bump rdkafka from 0.32.2 to 0.33.2 (#17891)
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Bumps [rdkafka](https://github.com/fede1024/rust-rdkafka) from 0.32.2 to
0.33.2.
<details>
<summary>Changelog</summary>
<p><em>Sourced from <a
href="https://github.com/fede1024/rust-rdkafka/blob/master/changelog.md">rdkafka's
changelog</a>.</em></p>
<blockquote>
<h2>0.33.2 (2023-07-06)</h2>
<ul>
<li><strong>Breaking change.</strong> Change signature for
<code>seek_partitions</code>. Following
librdkafka, individual partition errors should be reported in the
per-partition
<code>error</code> field of <code>TopicPartitionList</code>
elements.</li>
</ul>
<h2>0.33.0 (2023-06-30)</h2>
<ul>
<li>Add interface to specify custom partitioners by extending
<code>ProducerContext</code>
trait with capability to return optional custom partitioner.</li>
<li>Add <code>seek_partitions</code> to consumer.</li>
</ul>
<h2>0.32.1 (2023-06-09)</h2>
<ul>
<li>Add support for the cluster mock API.</li>
<li>Expose assignment_lost method on the consumer.</li>
</ul>
<h2>0.31.0 (2023-05-17)</h2>
<ul>
<li><strong>Breaking change.</strong> Pass <code>KafkaError</code> to
rebalance hooks instead of human-readable string
representation.</li>
</ul>
<h2>0.30.0 (2023-05-12)</h2>
<ul>
<li>
<p>Support for unassigning static partitions by passing
<code>null</code> to <code>rdsys::rd_kafka_assign</code> and expose the
feature as <code>unassign</code> in <code>base_consumer</code></p>
</li>
<li>
<p>Expose <code>rdsys::rd_kafka_incremental_assign</code> and
<code>rdsys::rd_kafka_incremental_unassign</code> in
<code>base_consumer</code> for
incremental changes to static assignments</p>
</li>
<li>
<p><strong>Breaking change.</strong>
<code>util::get_rdkafka_version</code> now returns <code>(i32,
String)</code>.
Previously, it returned <code>(u16, String)</code> which would silently
truncate the hex
representation of the version:</p>
<blockquote>
<p>Interpreted as hex MM.mm.rr.xx:</p>
<p>MM = Major
mm = minor
rr = revision
xx = pre-release id (0xff is the final release)
E.g.: 0x010902ff = 1.9.2</p>
</blockquote>
</li>
<li>
<p>Add the <code>AdminClient::delete_groups</code> method, which deletes
consumer groups
from a Kafka cluster (<a
href="https://redirect.github.com/fede1024/rust-rdkafka/issues/510">#510</a>).</p>
<p>Thanks, <a
href="https://github.com/andrewinci"><code>@​andrewinci</code></a>.</p>
</li>
</ul>
<p><a
href="https://redirect.github.com/fede1024/rust-rdkafka/issues/510">#510</a>:
<a
href="https://redirect.github.com/fede1024/rust-rdkafka/issues/510">fede1024/rust-rdkafka#510</a></p>
<ul>
<li>Add support for the <code>purge</code> API, that allows retreiving
messages that were</li>
</ul>
<!-- raw HTML omitted -->
</blockquote>
<p>... (truncated)</p>
</details>
<details>
<summary>Commits</summary>
<ul>
<li><a
href="https://github.com/fede1024/rust-rdkafka/commit/1c35b03487f88a3bf910ff17875a6b6d52dd5ada"><code>1c35b03</code></a>
Release v0.33.2.</li>
<li><a
href="https://github.com/fede1024/rust-rdkafka/commit/551362525d4ee057e92344035add103ed4903db3"><code>5513625</code></a>
Release v0.33.1.</li>
<li><a
href="https://github.com/fede1024/rust-rdkafka/commit/a244889c161538aee1f75ad6a39e45746425cc32"><code>a244889</code></a>
Merge pull request <a
href="https://redirect.github.com/fede1024/rust-rdkafka/issues/596">#596</a>
from fede1024/scanterog/seek-partitions</li>
<li><a
href="https://github.com/fede1024/rust-rdkafka/commit/020700d7bee43576ee82b441a7ada471bd4cc6ba"><code>020700d</code></a>
Add test for seek_partitions</li>
<li><a
href="https://github.com/fede1024/rust-rdkafka/commit/7f266b18e6753895212d9b009de03b9ef698069e"><code>7f266b1</code></a>
Change signature for seek_partitions</li>
<li><a
href="https://github.com/fede1024/rust-rdkafka/commit/e27049fe0d1c11d7f6751043af0449ae703062c9"><code>e27049f</code></a>
Release v0.33.0.</li>
<li><a
href="https://github.com/fede1024/rust-rdkafka/commit/d036b2ebf3d67e7f1572990b2bbc23c599a9660e"><code>d036b2e</code></a>
Merge pull request <a
href="https://redirect.github.com/fede1024/rust-rdkafka/issues/592">#592</a>
from mlowicki/master</li>
<li><a
href="https://github.com/fede1024/rust-rdkafka/commit/740f172e361ef209ae8786836b7dae1c918cb9cd"><code>740f172</code></a>
changes to generic params to make everything backward compatible</li>
<li><a
href="https://github.com/fede1024/rust-rdkafka/commit/ab684c82146a4004cd2f6420b84bebdec5939347"><code>ab684c8</code></a>
review</li>
<li><a
href="https://github.com/fede1024/rust-rdkafka/commit/ab62d590fc9835bed9644adbe3148fc63fe5a096"><code>ab62d59</code></a>
adjust comment + extra test</li>
<li>Additional commits viewable in <a
href="https://github.com/fede1024/rust-rdkafka/compare/v0.32.2...v0.33.2">compare
view</a></li>
</ul>
</details>
<br />


[![Dependabot compatibility
score](https://dependabot-badges.githubapp.com/badges/compatibility_score?dependency-name=rdkafka&package-manager=cargo&previous-version=0.32.2&new-version=0.33.2)](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores)

Dependabot will resolve any conflicts with this PR as long as you don't
alter it yourself. You can also trigger a rebase manually by commenting
`@dependabot rebase`.

[//]: # (dependabot-automerge-start)
[//]: # (dependabot-automerge-end)

---

<details>
<summary>Dependabot commands and options</summary>
<br />

You can trigger Dependabot actions by commenting on this PR:
- `@dependabot rebase` will rebase this PR
- `@dependabot recreate` will recreate this PR, overwriting any edits
that have been made to it
- `@dependabot merge` will merge this PR after your CI passes on it
- `@dependabot squash and merge` will squash and merge this PR after
your CI passes on it
- `@dependabot cancel merge` will cancel a previously requested merge
and block automerging
- `@dependabot reopen` will reopen this PR if it is closed
- `@dependabot close` will close this PR and stop Dependabot recreating
it. You can achieve the same result by closing it manually
- `@dependabot ignore this major version` will close this PR and stop
Dependabot creating any more for this major version (unless you reopen
the PR or upgrade to it yourself)
- `@dependabot ignore this minor version` will close this PR and stop
Dependabot creating any more for this minor version (unless you reopen
the PR or upgrade to it yourself)
- `@dependabot ignore this dependency` will close this PR and stop
Dependabot creating any more for this dependency (unless you reopen the
PR or upgrade to it yourself)


</details>

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
---
 Cargo.lock | 4 ++--
 Cargo.toml | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/Cargo.lock b/Cargo.lock
index eb9365fb3ca07..8359353b53d48 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -6667,9 +6667,9 @@ dependencies = [
 
 [[package]]
 name = "rdkafka"
-version = "0.32.2"
+version = "0.33.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "f8733bc5dc0b192d1a4b28073f9bff1326ad9e4fecd4d9b025d6fc358d1c3e79"
+checksum = "da18026aad1c24033da3da726200de7e911e75c2e2cc2f77ffb9b4502720faae"
 dependencies = [
  "futures-channel",
  "futures-util",
diff --git a/Cargo.toml b/Cargo.toml
index b15d12b5831c7..9edd234c92cd6 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -296,7 +296,7 @@ postgres-openssl = { version = "0.5.0", default-features = false, features = ["r
 pulsar = { version = "6.0.1", default-features = false, features = ["tokio-runtime", "auth-oauth2", "flate2", "lz4", "snap", "zstd"], optional = true }
 rand = { version = "0.8.5", default-features = false, features = ["small_rng"] }
 rand_distr = { version = "0.4.3", default-features = false }
-rdkafka = { version = "0.32.2", default-features = false, features = ["tokio", "libz", "ssl", "zstd"], optional = true }
+rdkafka = { version = "0.33.2", default-features = false, features = ["tokio", "libz", "ssl", "zstd"], optional = true }
 redis = { version = "0.23.0", default-features = false, features = ["connection-manager", "tokio-comp", "tokio-native-tls-comp"], optional = true }
 regex = { version = "1.8.4", default-features = false, features = ["std", "perf"] }
 roaring = { version = "0.10.1", default-features = false, optional = true }