Skip to content

support CDC with tablets #136

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wants to merge 11 commits into
base: main
Choose a base branch
from
Open

support CDC with tablets #136

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
11 commits
Select commit Hold shift + click to select a range
5eb0ed7
fix cli arguments in printer
mlitvk Sep 12, 2025
cadee17
add GenerationFetcher trait
mlitvk Sep 12, 2025
3955021
add TabletsGenerationFetcher
mlitvk Sep 12, 2025
d89684a
test generation fetcher
mlitvk Sep 14, 2025
7b7e43b
add uses_tablets method
mlitvk Sep 13, 2025
4e102e8
select appropriate generation fetcher
mlitvk Sep 13, 2025
c6a7441
add tablets parameter to prepare_db
mlitvk Sep 13, 2025
c0ab7a6
test stream_reader with tablets
mlitvk Sep 13, 2025
a224917
test e2e with tablets
mlitvk Sep 13, 2025
356e4e6
test replication with tablets
mlitvk Sep 15, 2025
3a18e49
skip tablets test if not supported
mlitvk Sep 17, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion scylla-cdc-printer/src/main.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ struct Args {
table: String,

/// Address of a node in source cluster
#[clap(short, long, action = clap::ArgAction::Set)]
#[clap(long, action = clap::ArgAction::Set)]
hostname: String,

/// Window size in seconds
Expand Down
2 changes: 1 addition & 1 deletion scylla-cdc-printer/src/printer.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -129,7 +129,7 @@ mod tests {
let start = now();
let end = start + chrono::Duration::seconds(2);

let (shared_session, ks) = prepare_simple_db().await.unwrap();
let (shared_session, ks) = prepare_simple_db(false).await.unwrap();

let partition_key_1 = 0;
let partition_key_2 = 1;
Expand Down
1 change: 1 addition & 0 deletions scylla-cdc-replicator/Cargo.toml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -21,3 +21,4 @@ thiserror = "2.0"

[dev-dependencies]
scylla-cdc-test-utils = { path = "../scylla-cdc-test-utils" }
rstest = "0.26.1"
Loading