@ -72,5 +72,14 @@ public class PendingEntry {
public long getLastTimeDelivered() {
return lastTimeDelivered;
}
@Override
public String toString() {
return "PendingEntry{" +
"id=" + id +
", consumerName='" + consumerName + '\'' +
", idleTime=" + idleTime +
", lastTimeDelivered=" + lastTimeDelivered +
'}';
@ -96,4 +96,16 @@ public class StreamGroup {
public int getLag() {
return lag;
return "StreamGroup{" +
"name='" + name + '\'' +
", consumers=" + consumers +
", pending=" + pending +
", lastDeliveredId=" + lastDeliveredId +
", entriesRead=" + entriesRead +
", lag=" + lag +