Collection<List<EventID>> getChunks(List<EventID> events, int size) {
    AtomicInteger counter = new AtomicInteger(0);
    return events.stream().collect(Collectors.groupingBy(event -> counter.getAndIncrement() / size))
        .values();
  }
expiry time for ThreadIdentifiers. In seconds.
geode-core/src/main/java/org/apache/geode/internal/cache/ha/HARegionQueue.java