adjust log level in Producer (#158)

Author: daleiz

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

@@ -103,7 +103,7 @@ class BufferedProducerKtImpl(
             val records = shardAppendBuffer[shardId]!!
             val futures = shardAppendFutures[shardId]!!
             val recordsBytesSize = shardAppendBytesSize[shardId]!!
-            logger.info("ready to flush recordBuffer for shard:$shardId, current buffer size is [{}]", records.size)
+            logger.debug("ready to flush recordBuffer for shard:$shardId, current buffer size is [{}]", records.size)
             shardAppendBuffer.remove(shardId)
             shardAppendFutures.remove(shardId)
             shardAppendBytesSize.remove(shardId)
@@ -115,7 +115,7 @@ class BufferedProducerKtImpl(
                 result?.await()
                 result = null
                 writeShard(shardId, records, futures)
-                logger.info("wrote batch for shard:$shardId")
+                logger.debug("wrote batch for shard:$shardId")
                 flowController?.release(recordsBytesSize)
                 Unit
             }

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

@@ -135,7 +135,7 @@ open class ProducerKtImpl(private val client: HStreamClientKtImpl, private val s
         check(tryTimes > 0)
 
         val serverUrl = lookupServerUrl(shardId, forceUpdate)
-        logger.info("try append with serverUrl [{}], current left tryTimes is [{}]", serverUrl, tryTimes)
+        logger.debug("try append with serverUrl [{}], current left tryTimes is [{}]", serverUrl, tryTimes)
         return try {
             client.getCoroutineStub(serverUrl)
                 .append(appendRequest).recordIdsList.map(GrpcUtils::recordIdFromGrpc)