From a69485d349b2850ae4cc0fc8fc8f2d2c441a37cd Mon Sep 17 00:00:00 2001 From: dengziming Date: Sun, 12 Jan 2020 14:06:38 +0800 Subject: [PATCH] [MINOR]: Fix typos --- .../org/apache/kafka/clients/consumer/internals/Fetcher.java | 2 +- 1 file changed, 1 insertion(+), 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 a162ddbf12ae8..2cbd398b0fcb6 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 @@ -1356,7 +1356,7 @@ public void clearBufferedDataForUnassignedTopics(Collection assignedTopi clearBufferedDataForUnassignedPartitions(currentTopicPartitions); } - // Visibilty for testing + // Visible for testing protected FetchSessionHandler sessionHandler(int node) { return sessionHandlers.get(node); }