docs: @SuppressWarnings("unchecked")
    public static void registerTopologyTimerEvents(Map<String, Object> conf,
                                                   String name, Duration interval,
                                                   Runnable task) {
      if (interval.isZero() || interval.isNegative()) {
        throw new IllegalArgumentException("Timer duration needs to be positive");
      }
      if (!conf.containsKey(Config.TOPOLOGY_TIMER_EVENTS)) {
        conf.put(Config.TOPOLOGY_TIMER_EVENTS, new HashMap<String, Pair<Duration, Runnable>>());
      }
  
      Map<String, Pair<Duration, Runnable>> timers
          = (Map<String, Pair<Duration, Runnable>>) conf.get(Config.TOPOLOGY_TIMER_EVENTS);
  
      if (timers.containsKey(name)) {
        throw new IllegalArgumentException("Timer with name " + name + " already exists");
      }
      timers.put(name, Pair.of(interval, task));
    }