Skip to content

feat(streaming): implement checkpoint coordination with catalog-backed crash recovery #159

feat(streaming): implement checkpoint coordination with catalog-backed crash recovery

feat(streaming): implement checkpoint coordination with catalog-backed crash recovery #159

# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
name: Integration Tests
on:
push:
branches: ["main", "master"]
pull_request:
branches: ["main", "master"]
workflow_dispatch:
env:
CARGO_TERM_COLOR: always
jobs:
integration-test:
name: Integration Tests
runs-on: ubuntu-latest
timeout-minutes: 180
steps:
- name: Checkout Source
uses: actions/checkout@v4
- name: Verify Docker
run: docker version
- name: Setup Python
uses: actions/setup-python@v5
with:
python-version: "3.11"
cache: "pip"
- name: Setup Rust
uses: dtolnay/rust-toolchain@stable
- name: Install System Dependencies
run: |
sudo apt-get update
sudo apt-get install -y --no-install-recommends \
cmake \
libssl-dev \
libcurl4-openssl-dev \
pkg-config \
libsasl2-dev \
protobuf-compiler
- name: Cache Cargo
uses: Swatinem/rust-cache@v2
- name: Build Release Binary
run: make env && make dist
- name: Pre-pull Kafka Image
run: docker pull apache/kafka:3.7.0
- name: Run Integration Tests
run: make integration-test
- name: Upload Test Logs
if: failure()
uses: actions/upload-artifact@v4
with:
name: integration-test-logs
path: tests/integration/target/**/logs/
retention-days: 30