ZK connection keepalive demonstartion

zk_test.go

package kafka

import (
	"testing"
	"time"

	"github.com/samuel/go-zookeeper/zk"
)

func TestDiscoverKafka(t *testing.T) {

	conn, events, err := zk.Connect([]string{"localhost:2181"}, 5*time.Second)
	if err != nil {
		t.Errorf("connection error: %v", err)
	}
	fmt.Println("connection state:", conn.State())
	quit := make(chan bool)
	go func() {
		for e := range events {

			fmt.Println("got event type", e.Type)
			fmt.Println("got event error", e.Err)
			fmt.Println("got event state", e.State)
			fmt.Println("got event path", e.Path)
			fmt.Println("got event server", e.Server)
		}
		fmt.Println("quitting")
		quit <- true
	}()

	fmt.Println("initial conn state:", conn.State())

	<-quit
}