docs: public void stop() {
          try {
              if (CollectionUtils.isEmpty(consumer.subscription())) {
                  consumer.unsubscribe();
              }
          } finally {
              consumer.close(Duration.ofMillis(10 * 1000L));
          }
      }