VOL-2861 replace uint64 kafka interadapter timestamps with timestamp proto
Change-Id: I7bf9abbdb590ac193b1d769f46cddc01b0ac2efb
diff --git a/rw_core/core/device/agent_test.go b/rw_core/core/device/agent_test.go
index ce69599..60b7273 100755
--- a/rw_core/core/device/agent_test.go
+++ b/rw_core/core/device/agent_test.go
@@ -25,6 +25,7 @@
"github.com/opencord/voltha-lib-go/v3/pkg/db"
"github.com/opencord/voltha-lib-go/v3/pkg/db/kvstore"
"github.com/opencord/voltha-lib-go/v3/pkg/kafka"
+ "github.com/opencord/voltha-lib-go/v3/pkg/log"
mock_etcd "github.com/opencord/voltha-lib-go/v3/pkg/mocks/etcd"
mock_kafka "github.com/opencord/voltha-lib-go/v3/pkg/mocks/kafka"
ofp "github.com/opencord/voltha-protos/v3/go/openflow_13"
@@ -198,7 +199,7 @@
func setupKVClient(cf *config.RWCoreFlags, coreInstanceID string) kvstore.Client {
addr := cf.KVStoreHost + ":" + strconv.Itoa(cf.KVStorePort)
- client, err := kvstore.NewEtcdClient(addr, cf.KVStoreTimeout)
+ client, err := kvstore.NewEtcdClient(addr, cf.KVStoreTimeout, log.FatalLevel)
if err != nil {
panic("no kv client")
}