@Override
        public void verify() {
            cluster.leaderHighWatermark().ifPresent(highWatermark -> {
                long numReachedHighWatermark = cluster.nodes.entrySet().stream()
                    .filter(entry -> cluster.voters.containsKey(entry.getKey()))
                    .filter(entry -> entry.getValue().log.endOffset().offset() >= highWatermark)
                    .count();
                assertTrue(
                    numReachedHighWatermark >= cluster.majoritySize(),
                    "Insufficient nodes have reached current high watermark");
            });
        }
Returns if the message should be sent to the destination.

Returns false when outbound request messages contains a destination {@code Node} that
matches the set of unreachable {@code InetSocketAddress}. Note that the {@code Node.id()}
and {@code Node.rack()} are not compared.

@param message the raft message
@return true if the message should be delivered, otherwise false
raft/src/test/java/org/apache/kafka/raft/RaftEventSimulationTest.java