Skip to content

Commit

Permalink
Make default consistency level to be LOCAL_QUORUM (#23)
Browse files Browse the repository at this point in the history
  • Loading branch information
dkropachev authored Aug 19, 2024
1 parent f6e8c10 commit 6bbd6f9
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions reader.go
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ type ReaderConfig struct {
TableNames []string

// Consistency to use when querying CDC log.
// If not specified, QUORUM consistency will be used.
// If not specified, LOCAL_QUORUM consistency will be used.
Consistency gocql.Consistency

// Creates ChangeProcessors, which process information fetched from the CDC log.
Expand Down Expand Up @@ -55,8 +55,8 @@ func (rc *ReaderConfig) validate() error {
func (rc *ReaderConfig) setDefaults() {
if rc.Consistency == 0 {
// Consistency 0 is ANY. It doesn't make sense
// to use it for reading, so default to QUORUM instead
rc.Consistency = gocql.Quorum
// to use it for reading, so default to LOCAL_QUORUM instead
rc.Consistency = gocql.LocalQuorum
}
if rc.ProgressManager == nil {
rc.ProgressManager = noProgressManager{}
Expand Down

0 comments on commit 6bbd6f9

Please sign in to comment.