VOL-2861 replace uint64 kafka interadapter timestamps with timestamp proto
Change-Id: I7bf9abbdb590ac193b1d769f46cddc01b0ac2efb
diff --git a/rw_core/core/api/common_test.go b/rw_core/core/api/common_test.go
index f6f07f5..f9bb047 100644
--- a/rw_core/core/api/common_test.go
+++ b/rw_core/core/api/common_test.go
@@ -99,7 +99,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")
}