fixed musl conflict (#81)

Signed-off-by: [email protected] <[email protected]>

Author: pranav-bhatt

.github/workflows/master.yml

@@ -22,7 +22,7 @@ jobs:
     - uses: actions/checkout@v2
     - run: sudo apt-get update
       if: matrix.target == 'x86_64-unknown-linux-musl'
-    - run: sudo apt-get install -y musl musl-dev musl-tools
+    - run: sudo apt-get install -y musl musl-dev musl-tools cmake
       if: matrix.target == 'x86_64-unknown-linux-musl'
     - name: Cache cargo registry
       uses: actions/cache@v1
@@ -59,20 +59,25 @@ jobs:
         toolchain: ${{ matrix.toolchain }}
         args: --target ${{ matrix.target }} --workspace
 
-    # If musl, compile and test all excluding kafka
+    # If musl, compile and test all
     - uses: actions-rs/cargo@v1
       if: matrix.target == 'x86_64-unknown-linux-musl'
       with:
         command: build
         toolchain: ${{ matrix.toolchain }}
-        args: --target ${{ matrix.target }} --workspace --exclude cloudevents-sdk-rdkafka
+        args: --target ${{ matrix.target }} --workspace
+      env:
+        CC: musl-gcc
+        CXX: g++
     - uses: actions-rs/cargo@v1
       if: matrix.target == 'x86_64-unknown-linux-musl'
       with:
         command: test
         toolchain: ${{ matrix.toolchain }}
-        args: --target ${{ matrix.target }} --workspace --exclude cloudevents-sdk-rdkafka
-
+        args: --target ${{ matrix.target }} --workspace
+      env:
+        CC: musl-gcc
+        CXX: g++
     # If wasm, then we test only the main module and cloudevents-sdk-reqwest
     - uses: actions-rs/cargo@v1
       if: matrix.target == 'wasm32-unknown-unknown'

cloudevents-sdk-rdkafka/Cargo.toml

@@ -15,7 +15,8 @@ readme = "README.md"
 bytes = "^0.5"
 cloudevents-sdk = { version = "0.2.0", path = ".." }
 lazy_static = "1.4.0"
-rdkafka = "^0.23"
+rdkafka = { version = "^0.24", features = ["cmake-build"] }
+
 
 [dev-dependencies]
 url = { version = "^2.1" }

cloudevents-sdk-rdkafka/src/lib.rs

@@ -7,6 +7,7 @@
 //!
 //! use cloudevents::Event;
 //! use rdkafka::producer::{FutureProducer, FutureRecord};
+//! use rdkafka::util::Timeout;
 //! use cloudevents_sdk_rdkafka::{MessageRecord, FutureRecordExt};
 //!
 //! # async fn produce(producer: &FutureProducer, event: Event) {
@@ -17,7 +18,7 @@
 //!     FutureRecord::to("topic")
 //!         .key("some_event")
 //!         .message_record(&message_record),
-//!     0
+//!     Timeout::Never
 //! ).await;
 //!
 //! # }