@@ -407,7 +407,9 @@ void xgroupCreate() {
407407
408408 @ Test
409409 @ EnabledOnCommand ("EVAL_RO" ) // Redis 7.0
410- void xgroupCreateEntriesRead () {
410+ void xgroupCreateEntriesRead_pre822 () {
411+ assumeTrue (RedisConditions .of (redis ).getRedisVersion ().isLessThan (RedisConditions .Version .parse ("8.2.2" )),
412+ "Redis 8.2.2+ has different behavior for entries-read" );
411413
412414 redis .xgroupCreate (StreamOffset .latest (key ), "group" , XGroupCreateArgs .Builder .entriesRead (5 ).mkstream (true ));
413415
@@ -416,6 +418,21 @@ void xgroupCreateEntriesRead() {
416418 assertThat (group .get (0 )).containsSequence ("entries-read" , 5L , "lag" );
417419 }
418420
421+ @ Test
422+ @ EnabledOnCommand ("EVAL_RO" ) // Redis 7.0
423+ void xgroupCreateEntriesRead_post822 () {
424+ assumeTrue (RedisConditions .of (redis ).hasVersionGreaterOrEqualsTo ("8.2.2" ),
425+ "Redis 8.2.2+ has different behavior for entries-read" );
426+
427+ redis .xadd (key , Collections .singletonMap ("key" , "value" ));
428+ redis .xadd (key , Collections .singletonMap ("key" , "value" ));
429+ redis .xgroupCreate (StreamOffset .latest (key ), "group" , XGroupCreateArgs .Builder .entriesRead (5 ).mkstream (true ));
430+
431+ List <List <Object >> group = (List ) redis .xinfoGroups ("key" );
432+
433+ assertThat (group .get (0 )).containsSequence ("entries-read" , 2L , "lag" );
434+ }
435+
419436 @ Test
420437 @ EnabledOnCommand ("XAUTOCLAIM" ) // Redis 6.2
421438 void xgroupCreateconsumer () {
0 commit comments