消费详情,未消费的消费组报错,菜单路由换成hash

This commit is contained in:
许晓东
2021-10-16 14:22:26 +08:00
parent b642647b2e
commit f18e857d3c
2 changed files with 11 additions and 6 deletions

View File

@@ -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()
}
}
})
})