| commit | ccfa21329b3154726b1447c83a2004d55694eab7 | [log] [tgz] |
|---|---|---|
| author | Kent Hagerman <khagerma@ciena.com> | Tue Dec 17 13:29:34 2019 -0500 |
| committer | Kent Hagerman <khagerma@ciena.com> | Wed Jan 22 12:05:52 2020 -0500 |
| tree | 58d49bcb05e83c068fdd2e64fdf658c7abf06671 | |
| parent | b38671ca6afaa7545d44840cc0e57f7c71e373c6 [diff] [blame] |
Added SubscribeForMetadata() to the sarama client, to access the header field of each received message. Also replaced TestKafkaClientImplementsKafkaClientIf() with static checks. For VOL-2207. Please consider these related patchsets together: https://gerrit.opencord.org/#/q/VOL-2207 Change-Id: I77f03fbb0ebcdf60cb5f8d0c8c3276325510e874
diff --git a/pkg/kafka/kafka_inter_container_library.go b/pkg/kafka/kafka_inter_container_library.go index 042e121..8285876 100644 --- a/pkg/kafka/kafka_inter_container_library.go +++ b/pkg/kafka/kafka_inter_container_library.go
@@ -520,7 +520,7 @@ Type: ic.MessageType_RESPONSE, FromTopic: request.Header.ToTopic, ToTopic: request.Header.FromTopic, - Timestamp: time.Now().Unix(), + Timestamp: time.Now().UnixNano(), } responseBody := &ic.InterContainerResponseBody{ Success: false,