diff --git a/pulsar-admin-jdk/src/main/java/io/github/protocol/pulsar/admin/jdk/SubscriptionStats.java b/pulsar-admin-jdk/src/main/java/io/github/protocol/pulsar/admin/jdk/SubscriptionStats.java index d35ec66..1c463a0 100644 --- a/pulsar-admin-jdk/src/main/java/io/github/protocol/pulsar/admin/jdk/SubscriptionStats.java +++ b/pulsar-admin-jdk/src/main/java/io/github/protocol/pulsar/admin/jdk/SubscriptionStats.java @@ -32,7 +32,7 @@ public class SubscriptionStats { public int chunkedMessageRate; - public int msgBacklog; + public long msgBacklog; public long backlogSize;