Skip to content

Commit

Permalink
Remove unused variable
Browse files Browse the repository at this point in the history
  • Loading branch information
ijuma committed Jan 29, 2020
1 parent 2bcdffd commit f9ae778
Showing 1 changed file with 0 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -531,7 +531,6 @@ private Node awaitNodeReady(FindCoordinatorRequest.CoordinatorType coordinatorTy
*/
private void handleProduceResponse(ClientResponse response, Map<TopicPartition, ProducerBatch> batches, long now) {
RequestHeader requestHeader = response.requestHeader();
long receivedTimeMs = response.receivedTimeMs();
int correlationId = requestHeader.correlationId();
if (response.wasDisconnected()) {
log.trace("Cancelled request with header {} due to node {} being disconnected",
Expand Down

0 comments on commit f9ae778

Please sign in to comment.