Add more info to test assertion

Author: acogoluegnes

src/test/java/com/rabbitmq/stream/impl/RecoveryClusterTest.java

@@ -157,28 +157,29 @@ void clusterRestart(boolean useLoadBalancer, boolean forceLeader) throws Interru
       Thread.sleep(BACK_OFF_DELAY_POLICY.delay(0).multipliedBy(2).toMillis());
 
       List<Tuple2<String, Sync>> streamsSyncs =
-          producers.stream().map(p -> of(p.stream(), p.waitForNewMessages(100))).collect(toList());
+          producers.stream().map(p -> of(p.stream(), p.waitForNewMessages(1000))).collect(toList());
       streamsSyncs.forEach(
           t -> {
             LOGGER.info("Checking publisher to {} still publishes", t._1());
             assertThat(t._2()).completes();
             LOGGER.info("Publisher to {} still publishes", t._1());
           });
 
-      syncs = consumers.stream().map(c -> c.waitForNewMessages(100)).collect(toList());
+      syncs = consumers.stream().map(c -> c.waitForNewMessages(1000)).collect(toList());
       syncs.forEach(s -> assertThat(s).completes());
 
       Map<String, Long> committedChunkIdPerStream = new LinkedHashMap<>(streamCount);
       streams.forEach(
           s ->
               committedChunkIdPerStream.put(s, environment.queryStreamStats(s).committedChunkId()));
 
-      syncs = producers.stream().map(p -> p.waitForNewMessages(100)).collect(toList());
+      syncs = producers.stream().map(p -> p.waitForNewMessages(1000)).collect(toList());
       syncs.forEach(s -> assertThat(s).completes());
 
       streams.forEach(
           s -> {
             assertThat(environment.queryStreamStats(s).committedChunkId())
+                .as("Committed chunk ID did not increase")
                 .isGreaterThan(committedChunkIdPerStream.get(s));
           });