Commit 72fbb1b
Rust stream tutorial 2 (#440)
* tutorial2: rust implementation
* replacing command key exit with Notify
* make received_messages variable local to the consuming thread
* adding a break when marker is detected
* bumping version of client
* removing consuming routine
* using first_offset and last_offset as Option instead of i641 parent 27616bf commit 72fbb1b
File tree
5 files changed
+316
-224
lines changed- rust-stream
- src/bin
5 files changed
+316
-224
lines changed
0 commit comments