diff --git a/src/main/scala/kafka/console/ConsumerConsole.scala b/src/main/scala/kafka/console/ConsumerConsole.scala index 022d59d..658974f 100644 --- a/src/main/scala/kafka/console/ConsumerConsole.scala +++ b/src/main/scala/kafka/console/ConsumerConsole.scala @@ -92,10 +92,15 @@ class ConsumerConsole(config: KafkaConfig) extends KafkaConsole(config: KafkaCon consumerGroup.members().asScala.filter(!_.assignment().topicPartitions().isEmpty).foreach(m => { m.assignment().topicPartitions().asScala.foreach(topicPartition => { - val t = topicPartitionConsumeInfoMap.get(topicPartition).get - t.clientId = m.clientId() - t.consumerId = m.consumerId() - t.host = m.host() + topicPartitionConsumeInfoMap.get(topicPartition) match { + case None => + case Some(t) => { + t.clientId = m.clientId() + t.consumerId = m.consumerId() + t.host = m.host() + } + } + }) }) diff --git a/ui/src/router/index.js b/ui/src/router/index.js index c47204c..e92c3f7 100644 --- a/ui/src/router/index.js +++ b/ui/src/router/index.js @@ -46,8 +46,8 @@ const routes = [ ]; const router = new VueRouter({ - mode: "history", - // mode: "hash", + // mode: "history", + mode: "hash", base: process.env.BASE_URL, routes, });