VOL-2861 replace uint64 kafka interadapter timestamps with timestamp proto
Change-Id: I7bf9abbdb590ac193b1d769f46cddc01b0ac2efb
diff --git a/rw_core/main.go b/rw_core/main.go
index 32af37a..4d99fbb 100644
--- a/rw_core/main.go
+++ b/rw_core/main.go
@@ -57,7 +57,7 @@
case "consul":
return kvstore.NewConsulClient(address, timeout)
case "etcd":
- return kvstore.NewEtcdClient(address, timeout)
+ return kvstore.NewEtcdClient(address, timeout, log.FatalLevel)
}
return nil, errors.New("unsupported-kv-store")
}