| commit | ed4a8e7a98d54de0009c4c0f792d24961b8c1cca | [log] [tgz] |
|---|---|---|
| author | Scott Baker <smbaker@gmail.com> | Fri Apr 17 11:10:20 2020 -0700 |
| committer | Scott Baker <smbaker@gmail.com> | Tue Apr 21 14:42:00 2020 -0700 |
| tree | db501d71d731fdcd06c8945e57b92db5df795d4f | |
| parent | 724d0854732023cb27a9f4b67a82c812061494a4 [diff] [blame] |
VOL-2861 replace uint64 kafka interadapter timestamps with timestamp proto Change-Id: I7b0fe854ff7c91984237a111789603129151dba3
diff --git a/internal/pkg/resourcemanager/resourcemanager.go b/internal/pkg/resourcemanager/resourcemanager.go index 3ed7441..a7f7730 100755 --- a/internal/pkg/resourcemanager/resourcemanager.go +++ b/internal/pkg/resourcemanager/resourcemanager.go
@@ -130,7 +130,7 @@ case "consul": return kvstore.NewConsulClient(address, int(timeout)) case "etcd": - return kvstore.NewEtcdClient(address, int(timeout)) + return kvstore.NewEtcdClient(address, int(timeout), log.FatalLevel) } return nil, errors.New("unsupported-kv-store") }