build: add unit tests for incremental fetch (#28)

* docs: update flamegraph

* build: add unit tests

* ci: update merge conditions

* feat: make fetch records more controllable.

* chore: remove dead code.

* fix(fetch): fetch records in order.

* build: add unit tests for incremental fetch

* chore(deps): bump `kafka-protocol` to 0.5.1

.mergify.yml

@@ -18,8 +18,8 @@ pull_request_rules:
     conditions:
       - or:
           - and:
-              - "#approved-reviews-by>=0"
-              - "#changes-requested-reviews-by=0"
+              - "#approved-reviews-by>=1"
+              - "#changes-requested-reviews-by=1"
               - -draft
               - check-success=fmt
               - check-success=test

Cargo.toml

@@ -26,7 +26,7 @@ fnv = "1"
 futures = "0.3"
 fxhash = "0.2"
 indexmap = "1"
-kafka-protocol = { git = "https://github.com/iamazy/kafka-protocol-rs", branch = "trunk"}
+kafka-protocol = { git = "https://github.com/iamazy/kafka-protocol-rs", rev = "d8a289bbdebd71f89d52838810303902a7368773"}
 native-tls = "0.2"
 pin-project-lite = "0.2"
 rand = "0.8"
@@ -37,9 +37,11 @@ tokio-util = { version = "0.7", features = ["codec"], optional = true }
 tokio-native-tls = { version = "0.3", optional = true }
 tracing = "0.1"
 url = "2.1"
-uuid = "0.8"
+uuid = "1.3"
 
 [dev-dependencies]
+rand = "0.8"
+pretty_assertions = "1"
 tokio = { version = "1", features = ["full"] }
 tracing-subscriber = "0.3"
 

README.md

@@ -85,7 +85,7 @@ Examples can be found in [`examples`](https://github.com/iamazy/kafkas/blob/main
 
 ## Flame graph
 
-<img style="width:800px" src="./benchmark/flamegraph.svg"  alt="flamegraph"/>
+<img style="width:800px" src="benches/flamegraph.svg"  alt="flamegraph"/>
 
 ## Rust version requirements