[ 
https://issues.apache.org/jira/browse/KAFKA-5374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16035664#comment-16035664
 ] 

Colin P. McCabe commented on KAFKA-5374:
----------------------------------------

This was introduced by KAFKA-5291.  The issue here is that the internal 
metadata requests being made by AdminClient were using 
{{allowAutoCreateTopics=false}}, which did not work with brokers older than 
0.11.

Unfortunately, NetworkClient doesn't handle this failure case well, and the 
failed internal metadata request responses were being returned back from the 
{{NetworkClient#poll}} call.  This caused the puzzling error message, since 
they had not been explicitly made by the {{AdminClient}}.

Since we are just making MetadataRequests for zero topics, there is no point in 
setting allowAutoCreateTopics=false anyway.  So I just set it to true in this 
patch.  I added a system test to the patch that will test a cross-version 
AdminClient call.  In the future, we should probably look into handling 
UnsupportedVersionException and other errors better in the internal metadata 
request code, but that's a bigger patch.

> AdminClient gets "server returned information about unknown correlation ID" 
> when communicating with older brokers
> -----------------------------------------------------------------------------------------------------------------
>
>                 Key: KAFKA-5374
>                 URL: https://issues.apache.org/jira/browse/KAFKA-5374
>             Project: Kafka
>          Issue Type: Bug
>          Components: admin
>    Affects Versions: 0.11.0.0
>            Reporter: Colin P. McCabe
>            Assignee: Colin P. McCabe
>            Priority: Blocker
>             Fix For: 0.11.0.0
>
>
> AdminClient gets "server returned information about unknown correlation ID" 
> when communicating with older brokers.
> The messages look like this:
> {code}
>  [2017-06-02 22:58:29,774] ERROR Internal server error on -2: server returned 
> information about unknown correlation ID 5 
> (org.apache.kafka.clients.admin.KafkaAdminClient)
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Reply via email to