diff --git a/.github/workflows/master.yml b/.github/workflows/master.yml index b85f09a..f2baa00 100644 --- a/.github/workflows/master.yml +++ b/.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' diff --git a/cloudevents-sdk-rdkafka/Cargo.toml b/cloudevents-sdk-rdkafka/Cargo.toml index 861315d..9dc02fc 100644 --- a/cloudevents-sdk-rdkafka/Cargo.toml +++ b/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" } diff --git a/cloudevents-sdk-rdkafka/src/lib.rs b/cloudevents-sdk-rdkafka/src/lib.rs index fbf52b0..76235fa 100644 --- a/cloudevents-sdk-rdkafka/src/lib.rs +++ b/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; //! //! # }