VOL-2861 replace uint64 kafka interadapter timestamps with timestamp proto
Change-Id: Ib7de52ce7a663b4817e383f03f34e4398d6c980d
diff --git a/pkg/kafka/client.go b/pkg/kafka/client.go
index 9abad93..0919a0c 100755
--- a/pkg/kafka/client.go
+++ b/pkg/kafka/client.go
@@ -66,7 +66,7 @@
DeleteTopic(topic *Topic) error
Subscribe(topic *Topic, kvArgs ...*KVArg) (<-chan *ca.InterContainerMessage, error)
UnSubscribe(topic *Topic, ch <-chan *ca.InterContainerMessage) error
- SubscribeForMetadata(func(fromTopic string, timestamp int64))
+ SubscribeForMetadata(func(fromTopic string, timestamp time.Time))
Send(msg interface{}, topic *Topic, keys ...string) error
SendLiveness() error
EnableLivenessChannel(enable bool) chan bool