ci: install zlib-dev

Author: crepererum

.circleci/config.yml

@@ -31,6 +31,15 @@ commands:
             - /usr/local/cargo/registry
           key: cargo-cache-{{ arch }}-{{ .Branch }}-{{ checksum "Cargo.toml" }}
 
+  install_zlib_dev:
+    description: Install zlib-dev
+    steps:
+      - run:
+          name: Install zlib-dev
+          command: |
+            sudo apt-get update
+            sudo apt-get install -y zlib1g-dev
+
 jobs:
   fmt:
     docker:
@@ -188,6 +197,7 @@ jobs:
       - checkout
       - rust_components
       - cache_restore
+      - install_zlib_dev
       - run:
           name: Cargo test
           command: cargo test --all-features --all-targets
@@ -253,6 +263,7 @@ jobs:
       - checkout
       - rust_components
       - cache_restore
+      - install_zlib_dev
       - run:
           name: Cargo test
           command: cargo test --all-features --all-targets

README.md

@@ -248,11 +248,8 @@ e.g. by batching writes to multiple partitions in a single ProduceRequest
 [Apache Kafka]: https://kafka.apache.org/
 [cargo-criterion]: https://github.com/bheisler/cargo-criterion
 [cargo-fuzz]: https://github.com/rust-fuzz/cargo-fuzz
-<<<<<<< HEAD
 [cargo-with]: https://github.com/cbourjau/cargo-with
-=======
 [gzip]: https://en.wikipedia.org/wiki/Gzip
->>>>>>> 4151626 (feat: support gzip compression)
 [IOx]: https://github.com/influxdata/influxdb_iox/
 [LLDB]: https://lldb.llvm.org/
 [perf]: https://perf.wiki.kernel.org/index.php/Main_Page

benches/write_throughput.rs

@@ -11,7 +11,7 @@ use futures::{stream::FuturesUnordered, StreamExt};
 use rdkafka::producer::FutureProducer;
 use rskafka::{
     client::{
-        partition::PartitionClient,
+        partition::{Compression, PartitionClient},
         producer::{aggregator::RecordAggregator, BatchProducerBuilder},
         ClientBuilder,
     },
@@ -81,7 +81,10 @@ pub fn criterion_benchmark(c: &mut Criterion) {
                     let start = Instant::now();
 
                     for _ in 0..iters {
-                        client.produce(vec![record.clone()]).await.unwrap();
+                        client
+                            .produce(vec![record.clone()], Compression::NoCompression)
+                            .await
+                            .unwrap();
                     }
 
                     start.elapsed()