From 583dc36d1ed219f1c40c9a12d24906eb6f86a2a7 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=AE=B8=E6=99=93=E4=B8=9C?= <763795151@qq.com>
Date: Sat, 13 Nov 2021 15:13:28 +0800
Subject: [PATCH] =?UTF-8?q?=E6=89=93=E5=8C=85=E8=B5=84=E6=BA=90=E6=96=87?=
 =?UTF-8?q?=E4=BB=B6=E5=8C=85=E5=90=AB?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/scala/kafka/console/ConsumerConsole.scala  | 10 +++++-----
 src/main/scala/kafka/console/OperationConsole.scala |  4 ++--
 2 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/src/main/scala/kafka/console/ConsumerConsole.scala b/src/main/scala/kafka/console/ConsumerConsole.scala
index e9ca8fb..d13d415 100644
--- a/src/main/scala/kafka/console/ConsumerConsole.scala
+++ b/src/main/scala/kafka/console/ConsumerConsole.scala
@@ -1,10 +1,5 @@
 package kafka.console
 
-import java.time.Duration
-import java.util
-import java.util.concurrent.TimeUnit
-import java.util.{Collections, Properties, Set}
-
 import com.xuxd.kafka.console.config.KafkaConfig
 import org.apache.kafka.clients.admin.ListOffsetsResult.ListOffsetsResultInfo
 import org.apache.kafka.clients.admin._
@@ -12,6 +7,10 @@ import org.apache.kafka.clients.consumer.{ConsumerConfig, OffsetAndMetadata, Off
 import org.apache.kafka.common.requests.ListOffsetsResponse
 import org.apache.kafka.common.{ConsumerGroupState, TopicPartition}
 
+import java.time.Duration
+import java.util
+import java.util.concurrent.TimeUnit
+import java.util.{Collections, Properties, Set}
 import scala.beans.BeanProperty
 import scala.collection.{Map, Seq, mutable}
 import scala.jdk.CollectionConverters._
@@ -154,6 +153,7 @@ class ConsumerConsole(config: KafkaConfig) extends KafkaConsole(config: KafkaCon
             strategy match {
                 case OffsetResetStrategy.EARLIEST => consumer.seekToBeginning(partitions.asJava)
                 case OffsetResetStrategy.LATEST => consumer.seekToEnd(partitions.asJava)
+                case _ =>
             }
             partitions.foreach(consumer.position(_))
             consumer.commitSync()
diff --git a/src/main/scala/kafka/console/OperationConsole.scala b/src/main/scala/kafka/console/OperationConsole.scala
index 53d0858..5d8ad35 100644
--- a/src/main/scala/kafka/console/OperationConsole.scala
+++ b/src/main/scala/kafka/console/OperationConsole.scala
@@ -85,7 +85,7 @@ class OperationConsole(config: KafkaConfig, topicConsole: TopicConsole,
             }
             (true, "")
         } catch {
-            case ex => {
+            case ex: Throwable => {
                 log.error("syncConsumerOffset error.", ex)
                 (false, ex.getMessage)
             }
@@ -155,7 +155,7 @@ class OperationConsole(config: KafkaConfig, topicConsole: TopicConsole,
             }
             (true, "")
         } catch {
-            case ex => {
+            case ex: Throwable => {
                 log.error("syncConsumerOffset error.", ex)
                 (false, ex.getMessage)
             }