查看Kafka隊列中的消息數，可以通過以下幾種方法：
kafka-console-consumer來消費消息，然后通過設置--from-beginning參數來獲取所有消息。命令如下：bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic <topic-name> --from-beginning
這會將所有的消息打印到終端，并在最后顯示消費的消息總數。
使用Kafka自帶的JMX接口來獲取隊列中的消息數。Kafka提供了JMX接口來監控和管理Kafka集群。你可以使用JMX客戶端工具（如JConsole、VisualVM等）連接到Kafka的JMX接口，并查看kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec指標的值，即代表入隊消息數的指標。
使用Kafka的Java客戶端API來獲取隊列中的消息數。你可以編寫一個簡單的Java程序，使用Kafka的Java客戶端API來連接到Kafka集群，并通過Consumer對象的position()方法來獲取當前消費者的位置（即已消費的消息數），然后減去beginningOffsets()方法返回的起始偏移量，即可得到隊列中的消息數。以下是一個示例代碼：
import org.apache.kafka.clients.consumer.*;
import java.util.*;
public class KafkaMessageCount {
public static void main(String[] args) {
String topicName = "<topic-name>";
String bootstrapServers = "localhost:9092";
Properties props = new Properties();
props.put("bootstrap.servers", bootstrapServers);
props.put("group.id", "test-group");
try (KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props)) {
consumer.subscribe(Collections.singletonList(topicName));
consumer.poll(0); // 必須在訂閱后調用poll()方法，以獲取分區分配
long beginningOffset = consumer.beginningOffsets(consumer.assignment()).values().iterator().next();
long currentPosition = consumer.position(consumer.assignment()).values().iterator().next();
long messageCount = currentPosition - beginningOffset;
System.out.println("隊列中的消息數: " + messageCount);
} catch (Exception e) {
e.printStackTrace();
}
}
}
將<topic-name>和localhost:9092替換為實際的主題和Kafka服務器地址，然后運行該代碼，即可獲取隊列中的消息數。
請注意，以上方法都是通過消費消息來獲取隊列中的消息數，因此可能會對集群產生一定的消耗。如果只是需要獲取消息數而不對消息進行消費，可以使用Kafka的管理工具、JMX接口或Kafka的Java客戶端API中的KafkaConsumer#endOffsets()方法來獲取每個分區的最新偏移量，并累加得到總消息數。
