Lucas Bradstreet created KAFKA-9200:
---------------------------------------

             Summary: ListOffsetRequest missing error response for v5
                 Key: KAFKA-9200
                 URL: https://issues.apache.org/jira/browse/KAFKA-9200
             Project: Kafka
          Issue Type: Bug
    Affects Versions: 2.3.0
            Reporter: Lucas Bradstreet
            Assignee: Lucas Bradstreet


It seems ListOffsetResponse getErrorResponse is missing a a case for version 5. 
I'd have hoped that this kind of case would be picked up by KafkaApisTest.
{noformat}
java.lang.IllegalArgumentException: Version 5 is not valid. Valid versions for 
ListOffsetRequest are 0 to 5                                                    
                                                                                
                                                                                
                                           
        at 
org.apache.kafka.common.requests.ListOffsetRequest.getErrorResponse(ListOffsetRequest.java:282)
                                                                                
                                                                                
                                                                                
                
        at 
kafka.server.KafkaApis.sendErrorOrCloseConnection(KafkaApis.scala:3062)         
                                                                                
                                                                                
                                                                                
                               
        at 
kafka.server.KafkaApis.sendErrorResponseMaybeThrottle(KafkaApis.scala:3045)     
                                                                                
                                                                                
                                                                                
                               
        at kafka.server.KafkaApis.handleError(KafkaApis.scala:3027)             
                                                                                
                                                                                
                                                                                
                                          
        at kafka.server.KafkaApis.handle(KafkaApis.scala:209)                   
                                                                                
                                                                                
                                                                                
                                          
        at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:78)   
                                                                                
                                                                                
                                                                                
                                          
        at java.lang.Thread.run(Thread.java:748)

{noformat}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to