We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 54b16fb commit 891e75dCopy full SHA for 891e75d
src/main/java/org/springframework/data/redis/connection/stream/StreamInfo.java
@@ -219,6 +219,8 @@ public Map<Object, Object> getLastEntry() {
219
* {@literal Redis Stream}.
220
*
221
* @author Christoph Strobl
222
+ * @author Mark Paluch
223
+ * @author Krzysztof Kocel
224
*/
225
public static class XInfoGroups implements Streamable<XInfoGroup> {
226
@@ -379,7 +381,7 @@ public Long entriesRead() {
379
381
380
382
@Nullable
383
public Long lag() {
- return get("entries-read", Long.class);
384
+ return get("lag", Long.class);
385
}
386
387
0 commit comments