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 (