dev

Author: RusovDmitriy

packages/cubejs-ksql-driver/src/KsqlDriver.ts

@@ -131,7 +131,9 @@ export class KsqlDriver extends BaseDriver implements DriverInterface {
     if (this.config.kafkaHost) {
       this.kafkaClient = new Kafka({
         clientId: 'Cube',
-        brokers: this.config.kafkaHost.split(','),
+        brokers: this.config.kafkaHost
+          .split(',')
+          .map(h => h.trim()),
         // authenticationTimeout: 10000,
         // reauthenticationThreshold: 10000,
         ssl: this.config.kafkaUseSsl,

rust/cubestore/cubestore/src/streaming/kafka.rs

@@ -311,7 +311,7 @@ impl StreamingSource for KafkaStreamingSource {
             .clone()
             .split(",")
             .filter(|s| !s.is_empty())
-            .map(|s| s.to_string())
+            .map(|s| s.trim().to_string())
             .collect();
         let stream = self
             .kafka_client