[KAFKA-5289] One StopReplicaRequest will caused two Responses

• Type: Bug
• Status: Resolved
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 0.10.0.0
• Fix Version/s: 0.11.0.0
• Component/s: core
• Flags: Patch, Important
• Assignee: Ismael Juma
• Reporter: ZanderXu
• Reviewer: Ma Tianchi
• Created: 19/May/17 08:43
• Updated: 25/Jul/17 11:11
• Resolved: 22/May/17 12:39

Description

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 175 lines 'requestChannel.sendResponse(new RequestChannel.Response(request, new ResponseSend(request.connectionId, responseHeader, response)))' and another at 111 lines 'requestChannel.sendResponse(new Response(request, new ResponseSend(request.connectionId, respHeader, response)))'.

Issue Links

• links to: GitHub Pull Request #3096