| commit | 731697e3194141e29ff0522a338a0e9e0c94402e | [log] [tgz] |
|---|---|---|
| author | khenaidoo <knursimu@ciena.com> | Tue Jan 29 16:03:29 2019 -0500 |
| committer | khenaidoo <knursimu@ciena.com> | Tue Jan 29 16:03:29 2019 -0500 |
| tree | e58156e67900cd8e0f34abfe79dd352c838d7b11 | |
| parent | bcf205b728fcf09ac801d7a35ceece99f5d7d94d [diff] [blame] |
[VOL-1435] Initial submission for device management integration tests. This update also comprises of some fixes with kafka consumer and random mac address generation. Change-Id: I4f8081752af646c3ed218ab17a541abb1b70cf5c
diff --git a/kafka/client.go b/kafka/client.go index 8cc1999..316a4a5 100644 --- a/kafka/client.go +++ b/kafka/client.go
@@ -26,7 +26,13 @@ ) const ( + OffsetNewest = -1 + OffsetOldest = -2 +) + +const ( GroupIdKey = "groupId" + Offset = "offset" ) const (