use client's timeout for Consumer (#168)

Author: daleiz

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

@@ -71,7 +71,7 @@ class ConsumerKtImpl(
         if (!isRunning) return
         val server = lookupSubscription()
         logger.debug("lookupSubscription, received:[$server]")
-        val stub = client.getCoroutineStub(server)
+        val stub = client.getCoroutineStubWithTimeout(server)
         try {
             // send an empty ack request to trigger streamingFetch.
             val initRequest = StreamingFetchRequest.newBuilder()

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

@@ -65,7 +65,7 @@ class HStreamClientKtImpl(bootstrapServerUrls: List<String>, private val request
         return HStreamApiGrpcKt.HStreamApiCoroutineStub(channelProvider.get(url))
     }
 
-    fun getCoroutineStubWithTimeout(url: String, timeoutSeconds: Long): HStreamApiGrpcKt.HStreamApiCoroutineStub {
+    fun getCoroutineStubWithTimeout(url: String, timeoutSeconds: Long = requestTimeoutMs): HStreamApiGrpcKt.HStreamApiCoroutineStub {
         return HStreamApiGrpcKt.HStreamApiCoroutineStub(channelProvider.get(url)).withDeadlineAfter(timeoutSeconds, TimeUnit.SECONDS)
     }