consumer: fix state transition when recv cancel code (#62)

Author: daleiz

.github/workflows/main.yml

@@ -34,7 +34,7 @@ jobs:
         run: ./gradlew ktlintCheck
 
       - name: Prepare test env
-        run:  script/prepare-test-env-latest.sh
+        run:  script/prepare-test-env.sh
 
       - name: Build and test with Gradle
         run: ./gradlew build 

client/src/main/kotlin/io/hstream/impl/ConsumerKtImpl.kt

@@ -59,8 +59,7 @@ class ConsumerKtImpl(
                 refreshServerUrl()
                 streamingFetchWithRetry(requestFlow)
             } else if (status.code == Status.CANCELLED.code) {
-                notifyStopped()
-                logger.info("consumer [{}] is stopped", consumerName)
+                // this means consumer closed actively, and do nothing here
             } else {
                 notifyFailed(HStreamDBClientException(e))
             }

script/prepare-test-env.sh

@@ -2,7 +2,7 @@
 
 set -e
 
-DEFAULT_HSTREAM_DOCKER_TAG="v0.6.0"
+DEFAULT_HSTREAM_DOCKER_TAG="v0.6.6"
 
 docker pull hstreamdb/hstream:${DEFAULT_HSTREAM_DOCKER_TAG} || true