diff --git a/document/contact/weixin_contact.jpg b/document/contact/weixin_contact.jpg index 4339826..57485bf 100644 Binary files a/document/contact/weixin_contact.jpg and b/document/contact/weixin_contact.jpg differ diff --git a/src/main/scala/kafka/console/KafkaConsole.scala b/src/main/scala/kafka/console/KafkaConsole.scala index 33d1345..cd8414c 100644 --- a/src/main/scala/kafka/console/KafkaConsole.scala +++ b/src/main/scala/kafka/console/KafkaConsole.scala @@ -63,6 +63,7 @@ class KafkaConsole(config: KafkaConfig) { case er: Exception => eh(er) } finally { + ConsumerCache.clearProperties() if (!config.isCacheConsumerConnection) { consumer.close() } @@ -252,7 +253,7 @@ object ConsumerCache { threadLocal.set(props) } - def clear() : Unit = { + def clearProperties() : Unit = { threadLocal.remove() } } \ No newline at end of file