code: public static void checkConfigSanity(final Properties config) {
          // auto-committing offsets should be disabled
          final Object autoCommit = config.getProperty("auto.commit.enable");
          if (autoCommit == null || Boolean.parseBoolean(String.valueOf(autoCommit))) {
              throw new IllegalArgumentException("kafka configuration 'auto.commit.enable' should be set to false for operation in storm");
          }
  
          // consumer timeout should not block calls indefinitely
          final Object consumerTimeout = config.getProperty("consumer.timeout.ms");
          if (consumerTimeout == null || Integer.parseInt(String.valueOf(consumerTimeout)) < 0) {
              throw new IllegalArgumentException("kafka configuration value for 'consumer.timeout.ms' is not suitable for operation in storm");
          }
      }
docs: Checks the sanity of a kafka consumer configuration for use in storm.
  
  @param config The configuration parameters to check.
  @throws IllegalArgumentException When a sanity check fails.