Check version when version is not (#345)

* Check version when version is not set and is less than 3.11
* Reduce the log level for the exchange version 

---------

Signed-off-by: Gabriele Santomaggio <g.santomaggio@gmail.com>

Author: Gsantomaggio

pkg/stream/available_features.go

@@ -45,7 +45,7 @@ func (a *availableFeatures) BrokerFilterEnabled() bool {
 func (a *availableFeatures) IsBrokerSingleActiveConsumerEnabled() bool {
 	lock.Lock()
 	defer lock.Unlock()
-	return a.brokerSingleActiveConsumerEnabled == a.is311OrMore
+	return a.brokerSingleActiveConsumerEnabled
 }
 
 func (a *availableFeatures) SetVersion(version string) error {

pkg/stream/client.go

@@ -212,9 +212,13 @@ func (c *Client) connect() error {
 			return err2
 		}
 
-		logs.LogDebug("Server properties: %s", c.serverProperties)
-		if serverProperties["version"] == "" {
-			logs.LogInfo(
+		err = c.availableFeatures.SetVersion(serverProperties["version"])
+		if err != nil {
+			logs.LogWarn("Error checking server version: %s", err)
+		}
+
+		if serverProperties["version"] == "" || !c.availableFeatures.Is311OrMore() {
+			logs.LogDebug(
 				"Server version is less than 3.11.0, skipping command version exchange")
 		} else {
 			err := c.exchangeVersion(c.serverProperties["version"])