From 4e3b32146b66079fa577cda6741cecb360b1cbe2 Mon Sep 17 00:00:00 2001
From: Robin Moffatt <robin@rmoff.net>
Date: Thu, 8 Oct 2020 16:11:23 +0100
Subject: [PATCH] Update test

---
 test/main.go  | 2 ++
 test/setup.go | 6 ++++--
 2 files changed, 6 insertions(+), 2 deletions(-)

diff --git a/test/main.go b/test/main.go
index 028e7cb..7b47f2c 100644
--- a/test/main.go
+++ b/test/main.go
@@ -10,6 +10,8 @@ import (
 )
 
 const ksqlDBServer string = "http://localhost:8088"
+const ksqlDBUser string = ""
+const ksqlDBPW string = ""
 
 func main() {
 
diff --git a/test/setup.go b/test/setup.go
index bccafac..d75e950 100644
--- a/test/setup.go
+++ b/test/setup.go
@@ -8,8 +8,10 @@ import (
 )
 
 func setup() (*ksqldb.Client, error) {
-	//create ksqldb client
-	client := ksqldb.NewClient(ksqlDBServer).Debug()
+
+	//create ksqlDB client
+	client := ksqldb.NewClient(ksqlDBServer, ksqlDBUser, ksqlDBPW).Debug()
+
 	// Create the dummy data connector
 	if err := client.Execute(`
 		CREATE SOURCE CONNECTOR DOGS WITH (