gRPC migration update
Change-Id: Icdd1a824948fa994cd36bd121c962f5ecf74e3cf
diff --git a/vendor/github.com/Shopify/sarama/describe_log_dirs_response.go b/vendor/github.com/Shopify/sarama/describe_log_dirs_response.go
index d207312..411da38 100644
--- a/vendor/github.com/Shopify/sarama/describe_log_dirs_response.go
+++ b/vendor/github.com/Shopify/sarama/describe_log_dirs_response.go
@@ -61,6 +61,10 @@
return r.Version
}
+func (r *DescribeLogDirsResponse) headerVersion() int16 {
+ return 0
+}
+
func (r *DescribeLogDirsResponse) requiredVersion() KafkaVersion {
return V1_0_0_0
}
@@ -80,6 +84,9 @@
return err
}
+ if err := pe.putArrayLength(len(r.Topics)); err != nil {
+ return err
+ }
for _, topic := range r.Topics {
if err := topic.encode(pe); err != nil {
return err
@@ -133,6 +140,9 @@
return err
}
+ if err := pe.putArrayLength(len(r.Partitions)); err != nil {
+ return err
+ }
for _, partition := range r.Partitions {
if err := partition.encode(pe); err != nil {
return err