From f9751afc1b04ba366569e602073127897505f3e5 Mon Sep 17 00:00:00 2001 From: dengziming Date: Tue, 30 Mar 2021 12:58:01 +0800 Subject: [PATCH] MINOR: Remove wrong suppress --- .../org/apache/kafka/clients/consumer/internals/Fetcher.java | 1 - 1 file changed, 1 deletion(-) diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java index 257cff6b206bf..8f9b7a2e5bc3b 100644 --- a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java +++ b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java @@ -276,7 +276,6 @@ public synchronized int sendFetches() { public void onSuccess(ClientResponse resp) { synchronized (Fetcher.this) { try { - @SuppressWarnings("unchecked") FetchResponse response = (FetchResponse) resp.responseBody(); FetchSessionHandler handler = sessionHandler(fetchTarget.id()); if (handler == null) {