Skip to content

Commit 69be588

Browse files
feat: Updating producer to configure RoutingPolicy - adding partition_key as the default for Round Robin if set (#366)
1 parent f2cbcf1 commit 69be588

File tree

4 files changed

+360
-40
lines changed

4 files changed

+360
-40
lines changed

Cargo.toml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,7 @@ futures = "^0.3.31"
3030
futures-rustls = { version = "^0.26.0", default-features = false, features = ["tls12", "logging"], optional = true } # replacement of crate async-rustls (also a fork of tokio-rustls)
3131
log = "^0.4.27"
3232
lz4 = { version = "^1.28.0", optional = true }
33+
murmur3 = "0.5.2"
3334
native-tls = { version = "^0.2.12", optional = true }
3435
nom = { version = "^7.1.3", default-features = false, features = ["alloc"] }
3536
openidconnect = { version = "^4.0.0", optional = true }

src/lib.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -223,6 +223,7 @@ pub mod message;
223223
pub mod producer;
224224
pub mod reader;
225225
mod retry_op;
226+
pub mod routing_policy;
226227
mod service_discovery;
227228

228229
#[cfg(all(

0 commit comments

Comments
 (0)