diff --git a/integration-tests/setup/testcluster.go b/integration-tests/setup/testcluster.go index 5261321..55ee74f 100644 --- a/integration-tests/setup/testcluster.go +++ b/integration-tests/setup/testcluster.go @@ -452,7 +452,7 @@ func NewTestConfig(originHost string, targetHost string) *config.Config { conf.ReadMode = config.ReadModePrimaryOnly conf.SystemQueriesMode = config.SystemQueriesModeOrigin conf.AsyncHandshakeTimeoutMs = 4000 - conf.ControlConnMaxProtocolVersion = "3" + conf.ControlConnMaxProtocolVersion = "DseV2" conf.ProxyRequestTimeoutMs = 10000 diff --git a/integration-tests/streamids_test.go b/integration-tests/streamids_test.go index 9e47e88..97eb943 100644 --- a/integration-tests/streamids_test.go +++ b/integration-tests/streamids_test.go @@ -23,7 +23,7 @@ import ( // if we notice greater stream ID value than expected. We cannot easily test // exceeding 127 stream IDs allowed in protocol V2, because clients will // fail serializing the frame -func TestMaxStreamIds(t *testing.T) { +func TestLimitStreamIdsGeneration(t *testing.T) { originAddress := "127.0.1.1" targetAddress := "127.0.1.2" originProtoVer := primitive.ProtocolVersion2 diff --git a/proxy/pkg/config/config.go b/proxy/pkg/config/config.go index 72e35ce..cc62842 100644 --- a/proxy/pkg/config/config.go +++ b/proxy/pkg/config/config.go @@ -25,7 +25,7 @@ type Config struct { ReplaceCqlFunctions bool `default:"false" split_words:"true" yaml:"replace_cql_functions"` AsyncHandshakeTimeoutMs int `default:"4000" split_words:"true" yaml:"async_handshake_timeout_ms"` LogLevel string `default:"INFO" split_words:"true" yaml:"log_level"` - ControlConnMaxProtocolVersion string `default:"3" split_words:"true" yaml:"control_conn_max_protocol_version"` // Numeric Cassandra OSS protocol version or DseV1 / DseV2 + ControlConnMaxProtocolVersion string `default:"DseV2" split_words:"true" yaml:"control_conn_max_protocol_version"` // Numeric Cassandra OSS protocol version or DseV1 / DseV2 // Proxy Topology (also known as system.peers "virtualization") bucket