docs: public void notifyShutdown() {
          if (m_shutdown.compareAndSet(false, true)) {
              for (KafkaExternalConsumerRunner consumer : m_consumers) {
                  consumer.shutdown();
              }
              close();
          }
      }