Fix test

practo · Dec 16, 2020 · 9e466db · 9e466db
1 parent e15b171
commit 9e466db
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/README.md b/README.md
@@ -10,7 +10,7 @@ Near real time cloud native data pipeline. Just another data pipeline.
 ## Install
 The pipeline is a combination of services deployed independently.
 
-- **RedshiftSink** Using the CRD written in this repo. [Instructions.](https://github.com/practo/tipoca-stream/blob/master/redshiftsink/README.md)
+- **RedshiftSink** Using the CRD written in this repo. [Instructions and code.](https://github.com/practo/tipoca-stream/blob/master/redshiftsink/README.md)
 ```
       kubectl get redshiftsink
 ```

diff --git a/pkg/consumer/kafka_watcher.go b/pkg/consumer/kafka_watcher.go
@@ -43,7 +43,7 @@ func NewKafkaWatcher(brokers []string, version string) (KafkaWatcher, error) {
 	err = broker.Open(nil)
 	if err != nil {
 		return nil, fmt.Errorf(
-			"Cannot connect to broker: %s, err: %v", broker, err)
+			"Cannot connect to broker: %s, err: %v", brokers[0], err)
 	}
 
 	return &kafkaWatch{