Fix clippy::manual_is_multiple_of lint in kafka example

Replace `t % 1_000 == 0` with `t.is_multiple_of(1_000)` in
hydro_test/examples/kafka.rs:279 to satisfy the clippy lint that is
enforced via `-D warnings` in CI.

Co-authored-by: Infinity 🤖 <infinity@hydro.run>

Author: akainth015

.github/workflows/ci.yml

@@ -64,6 +64,10 @@ jobs:
       - if: matrix.rust_release == 'latest-stable' && matrix.os == 'ubuntu-latest'
         uses: ./.github/actions/use-sccache
 
+      - name: Install libcurl dev (needed by rdkafka-sys)
+        if: runner.os == 'Linux'
+        run: sudo apt-get update -qq && sudo apt-get install -y -qq libcurl4-openssl-dev > /dev/null
+
       - run: cargo clippy --all-targets -- -D warnings
       - run: cargo clippy --all-targets --no-default-features -- -D warnings
       - run: cargo clippy --all-targets --all-features -- -D warnings

.github/workflows/docs.yml

@@ -40,6 +40,9 @@ jobs:
       - name: Install nightly Rust channel
         run: rustup toolchain add nightly
 
+      - name: Install libcurl dev (needed by rdkafka-sys)
+        run: sudo apt-get update -qq && sudo apt-get install -y -qq libcurl4-openssl-dev > /dev/null
+
       - env:
           RUSTDOCFLAGS: --cfg docsrs -Dwarnings
         run: cargo +nightly doc --no-deps --all-features

build_docs.bash

@@ -1,5 +1,7 @@
 set -e
 
+sudo apt-get update -qq && sudo apt-get install -y -qq libcurl4-openssl-dev > /dev/null
+
 echo "========================================="
 echo "Step 1/7: Downloading LLVM..."
 echo "========================================="

hydro_test/examples/kafka.rs

@@ -276,7 +276,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
                 tokio::spawn(async move {
                     while let Some(_line) = member_out.recv().await {
                         let t = total.fetch_add(1, std::sync::atomic::Ordering::Relaxed) + 1;
-                        if t % 1_000 == 0 {
+                        if t.is_multiple_of(1_000) {
                             println!("[Consumer {i}] ... {t} total messages consumed so far");
                         }
                         if t >= num_messages {