fix: Examples not producing output on consumer side (streamnative#261)

afonsosribeiro · Mar 1, 2023 · bcfa020 · bcfa020
1 parent c5c05cc
commit bcfa020
Show file tree

Hide file tree

Showing 2 changed files with 26 additions and 1 deletion.
diff --git a/examples/README.md b/examples/README.md
@@ -0,0 +1,25 @@
+# Examples
+
+In order to run these examples, you will need a running Apache-Pulsar backend. You can start one with:
+
+```bash
+docker run -it \
+  -p 6650:6650 \
+  -p 8080:8080 \
+  --mount source=pulsardata,target=/pulsar/data \
+  --mount source=pulsarconf,target=/pulsar/conf \
+  apachepulsar/pulsar:2.10.0 \
+  bin/pulsar standalone
+```
+
+## Producer
+
+```bash
+RUST_LOG=info cargo run --release --example producer
+```
+
+## Consumer
+
+```bash
+RUST_LOG=info cargo run --release --example consumer
+```
diff --git a/examples/producer.rs b/examples/producer.rs
@@ -75,7 +75,7 @@ async fn main() -> Result<(), pulsar::Error> {
             .unwrap();
 
         counter += 1;
-        println!("{counter} messages");
+        log::info!("{counter} messages");
         tokio::time::sleep(std::time::Duration::from_millis(1000)).await;
 
         if counter > 10 {