| commit | 396b652d368971ca4d513ee8c75b4f55a12459a6 | [log] [tgz] |
|---|---|---|
| author | Dinesh Belwalkar <dumbbel@gmail.com> | Thu Feb 06 22:11:53 2020 +0000 |
| committer | Dinesh Belwalkar <dumbbel@gmail.com> | Thu Feb 06 22:11:53 2020 +0000 |
| tree | 81d331e24bd46744cae5bbb39cdf0920d06c6e3e | |
| parent | 1a8f286a6bbee1bc783533538f0b4af971591ddc [diff] [blame] |
[SEBA-930] update GRPC version to 1.27 and change kafka message producing Change-Id: I14145a1351eb2523fa54e66381ad97abc5eedf50
diff --git a/vendor/github.com/Shopify/sarama/produce_set.go b/vendor/github.com/Shopify/sarama/produce_set.go index bba0f7e..b684aa4 100644 --- a/vendor/github.com/Shopify/sarama/produce_set.go +++ b/vendor/github.com/Shopify/sarama/produce_set.go
@@ -44,9 +44,10 @@ } timestamp := msg.Timestamp - if msg.Timestamp.IsZero() { + if timestamp.IsZero() { timestamp = time.Now() } + timestamp = timestamp.Truncate(time.Millisecond) partitions := ps.msgs[msg.Topic] if partitions == nil {