fix(kafka-deduplicator): handle clippy warning observed in dev (#38887)

eli-r-ph · web-flow · commit 0f5c95925a7b · 2025-09-30T14:43:33.000-07:00
diff --git a/rust/kafka-deduplicator/src/checkpoint_manager.rs b/rust/kafka-deduplicator/src/checkpoint_manager.rs
@@ -416,7 +416,8 @@ impl CheckpointManager {
             counter_for_partition = *counter_guard.get(partition).unwrap_or(&0_u32);
         }
 
-        if counter_for_partition % full_checkpoint_interval == 0 {
+        // when full_checkpoint_interval is 0, we default to always performing Full checkpoints
+        if counter_for_partition.is_multiple_of(full_checkpoint_interval) {
             CheckpointMode::Full
         } else {
             CheckpointMode::Incremental

Original file line number	Diff line number	Diff line change
`@@ -416,7 +416,8 @@ impl CheckpointManager {`
`416`	`416`	`counter_for_partition = *counter_guard.get(partition).unwrap_or(&0_u32);`
`417`	`417`	`}`
`418`	`418`
`419`		`- if counter_for_partition % full_checkpoint_interval == 0 {`
	`419`	`+ // when full_checkpoint_interval is 0, we default to always performing Full checkpoints`
	`420`	`+ if counter_for_partition.is_multiple_of(full_checkpoint_interval) {`
`420`	`421`	`CheckpointMode::Full`
`421`	`422`	`} else {`
`422`	`423`	`CheckpointMode::Incremental`