xuzq created KAFKA-5289:

             Summary: One StopReplicaRequest will caused two Responses
                 Key: KAFKA-5289
                 URL: https://issues.apache.org/jira/browse/KAFKA-5289
             Project: Kafka
          Issue Type: Bug
          Components: core
    Affects Versions:
            Reporter: xuzq
            Priority: Critical
         Attachments: 屏幕快照 2017-05-19 16.34.21.png

After discussed with my friend markTC,we find a bug.
One StopReplicaRequest will caused two Responses.
At core/src/main/scala/kafka/server/KafkaApi.class 175 and 176 lines.
When an exception caused at 
'replicaManager.replicaFetcherManager.shutdownIdleFetcherThreads()', will also 
return two responses,  one is at 'requestChannel.sendResponse(new 
RequestChannel.Response(request, new ResponseSend(request.connectionId, 
responseHeader, response)))' and another at 'requestChannel.sendResponse(new 
Response(request, new ResponseSend(request.connectionId, respHeader, 

This message was sent by Atlassian JIRA

Reply via email to