Results 2 issues of zenv

### What happened? System Architecture reported an error when I used ClickHouse as the storage backend,the error like this: ```text HTTP Error: plugin error:rpc error: code = Unknown desc =...

bug

> kafka as SparkStreaming input and output 1. Use `spark.readStream.format("kafka")` read kafka data and decode binary data to string 2. Use `df.map(_.Seq.foldLeft(""))(_ + separtor + _).writeStream("kafka")` output data to kafka...