[kafka] branch trunk updated: MINOR: Skip `Struct` conversion in `FetchRequest.parse` (#9740)

[ijuma]

This is an automated email from the ASF dual-hosted git repository.

ijuma pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 3572049  MINOR: Skip `Struct` conversion in `FetchRequest.parse` 
(#9740)
3572049 is described below

commit 3572049863ddc7a41c1549eaf23fad59d74f589f
Author: dengziming <dengziming1...@gmail.com>
AuthorDate: Mon Dec 14 00:36:37 2020 +0800

    MINOR: Skip `Struct` conversion in `FetchRequest.parse` (#9740)
    
    This was missed in 6f27bb0.
    
    Reviewers: Ismael Juma <ism...@juma.me.uk>
---
 .../src/main/java/org/apache/kafka/common/requests/FetchRequest.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java 
b/clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java
index b62c844..950b03e 100644
--- a/clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java
+++ b/clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java
@@ -20,6 +20,7 @@ import org.apache.kafka.common.IsolationLevel;
 import org.apache.kafka.common.TopicPartition;
 import org.apache.kafka.common.message.FetchRequestData;
 import org.apache.kafka.common.protocol.ApiKeys;
+import org.apache.kafka.common.protocol.ByteBufferAccessor;
 import org.apache.kafka.common.protocol.Errors;
 import org.apache.kafka.common.record.MemoryRecords;
 import org.apache.kafka.common.record.RecordBatch;
@@ -371,7 +372,7 @@ public class FetchRequest extends AbstractRequest {
     }
 
     public static FetchRequest parse(ByteBuffer buffer, short version) {
-        return new FetchRequest(new 
FetchRequestData(ApiKeys.FETCH.parseRequest(version, buffer), version), 
version);
+        return new FetchRequest(new FetchRequestData(new 
ByteBufferAccessor(buffer), version), version);
     }
 
     @Override