[Merged by Bors] - feat: Add Partitioner trait with SiphashRoundRobinPartitioner impl

examples/00-produce/src/main.rs

@@ -32,9 +32,9 @@ async fn main() {
 async fn produce() -> Result<(), fluvio::FluvioError> {
     let producer = fluvio::producer("simple").await?;
 
-    let record = "Hello, Fluvio!";
-    producer.send_record(&record, 0).await?;
-    println!("{}", &record);
+    let value = "Hello, Fluvio!";
+    producer.send_keyless(value).await?;
+    println!("{}", value);
 
     Ok(())
 }

examples/01-produce-key-value/Cargo.toml

@@ -10,3 +10,4 @@ publish = false
 [dependencies]
 fluvio = { path = "../../src/client" }
 async-std = { version = "1.8.0", default-features = false, features = ["attributes"] }
+tracing-subscriber = "0.2.17"

examples/01-produce-key-value/src/main.rs

@@ -23,6 +23,10 @@
 
 #[async_std::main]
 async fn main() {
+    let _ = tracing_subscriber::fmt()
+        .with_env_filter(tracing_subscriber::EnvFilter::from_default_env())
+        .try_init();
+
     if let Err(e) = produce_key_value().await {
         println!("Produce error: {:?}", e);
     }
@@ -34,6 +38,7 @@ async fn produce_key_value() -> Result<(), fluvio::FluvioError> {
     let key = "Hello";
     let value = "Fluvio";
 
+    println!("About to send");
     producer.send(key, value).await?;
     println!("[{}] {}", key, value);
     Ok(())

examples/03-echo/src/main.rs

@@ -138,13 +138,13 @@ async fn main() {
 async fn produce() -> Result<(), FluvioError> {
     let producer = fluvio::producer(TOPIC).await?;
 
-    for i in 0..10 {
+    for i in 0..10u32 {
         println!("Sending record {}", i);
         producer
             .send(format!("Key {}", i), format!("Value {}", i))
             .await?;
     }
-    producer.send_record("Done!", 0).await?;
+    producer.send_keyless("Done!").await?;
 
     Ok(())
 }

src/cli/src/consumer/produce/mod.rs

@@ -102,7 +102,7 @@ impl ProduceOpt {
         if self.kv_mode() {
             self.produce_key_value(producer, string).await?;
         } else {
-            producer.send_record(string, 0).await?;
+            producer.send_keyless(string).await?;
             if self.verbose {
                 println!("[null] {}", string);
             }

src/client/Cargo.toml

@@ -36,6 +36,7 @@ thiserror = "1.0.20"
 once_cell = "1.5.2"
 semver = "0.11.0"
 pin-project-lite = "0.2"
+siphasher = "0.3.5"
 
 # Fluvio dependencies
 fluvio-future = { version = "0.2.0", features = ["task", "native2_tls"] }
@@ -47,4 +48,5 @@ fluvio-protocol = { path = "../protocol", version = "0.4.0" }
 dataplane = { version = "0.4.1", path = "../dataplane-protocol", package = "fluvio-dataplane-protocol" }
 
 [dev-dependencies]
-async-std = { version = "1.6.4", default-features = false}
+async-std = { version = "1.6.4", default-features = false }
+fluvio-future = { version = "0.2.0", features = ["fixture"] }