if crypto.SSEC.IsRequested(headers) || crypto.SSECopy.IsRequested(headers) {
				return encrypted, errEncryptedObject
			}
		}

		if crypto.S3KMS.IsEncrypted(info.UserDefined) && r.Header.Get(xhttp.AmzCopySource) == "" {
			if crypto.SSEC.IsRequested(headers) || crypto.SSECopy.IsRequested(headers) {
				return encrypted, errEncryptedObject
			}
		}

import org.codelibs.fess.crawler.exception.CrawlingAccessException;
import org.codelibs.fess.crawler.exception.MaxLengthExceededException;
import org.codelibs.fess.crawler.helper.ContentLengthHelper;
import org.codelibs.fess.crawler.helper.MimeTypeHelper;
import org.codelibs.fess.crawler.helper.RobotsTxtHelper;
import org.codelibs.fess.crawler.util.CrawlingParameterUtil;

import jakarta.annotation.Resource;

/**

        LogNotificationHelper helper = new LogNotificationHelper();
        // destroy() without init() should not throw NPE because of null checks
        helper.destroy();
    }

    @Test
    public void test_init_destroy_multipleRounds() {
        LogNotificationHelper helper = new LogNotificationHelper();
        helper.init();
        helper.destroy();
        // Second round
        helper.init();

import org.apache.logging.log4j.core.config.plugins.PluginElement;
import org.apache.logging.log4j.core.config.plugins.PluginFactory;
import org.codelibs.fess.helper.LogNotificationHelper;
import org.codelibs.fess.helper.LogNotificationHelper.LogNotificationEvent;

/**
 * Custom Log4j2 Appender that captures log events into a buffer for notification purposes.
 */

	</component>
	<component name="labelTypeHelper" class="org.codelibs.fess.helper.LabelTypeHelper">
	</component>
	<component name="rateLimitHelper" class="org.codelibs.fess.helper.RateLimitHelper">
	</component>
	<component name="relatedContentHelper" class="org.codelibs.fess.helper.RelatedContentHelper">
	</component>
	<component name="relatedQueryHelper" class="org.codelibs.fess.helper.RelatedQueryHelper">
	</component>

	</component>
	<component name="indexingHelper" class="org.codelibs.fess.helper.IndexingHelper">
	</component>
	<component name="notificationHelper" class="org.codelibs.fess.helper.NotificationHelper">
	</component>
	<component name="logNotificationHelper" class="org.codelibs.fess.helper.LogNotificationHelper">
	</component>
	<component name="pathMappingHelper" class="org.codelibs.fess.helper.PathMappingHelper">

    static final class Helper<K, V>
        implements InternalEntryHelper<
            K, V, StrongKeyStrongValueEntry<K, V>, StrongKeyStrongValueSegment<K, V>> {
      private static final Helper<?, ?> INSTANCE = new Helper<>();

      @SuppressWarnings("unchecked")
      static <K, V> Helper<K, V> instance() {
        return (Helper<K, V>) INSTANCE;
      }

      @Override

      void addEntries(MoreObjects.ToStringHelper helper) {
        helper
            .add(SHORT_NAME, 10)
            .addValue(10L)
            .add(SHORT_NAME, 3.14f)
            .addValue(3.14d)
            .add(LONG_NAME, false)
            .add(LONG_NAME, LONG_NAME);
      }
    },
    CONDITIONAL {
      @Override
      void addEntries(MoreObjects.ToStringHelper helper) {
        helper
            .add(SHORT_NAME, "x")

        } catch (final Exception e) {
            return;
        }

        final LogNotificationHelper helper;
        try {
            helper = ComponentUtil.getLogNotificationHelper();
        } catch (final Exception e) {
            return;
        }

        final List<LogNotificationEvent> events = helper.drainAll();
        if (events.isEmpty()) {
            return;
        }

        try {

package notify

import (
	"fmt"
	"strconv"
	"strings"

	"github.com/minio/minio/internal/config"
	"github.com/minio/minio/internal/event/target"
)

// SetNotifyKafka - helper for config migration from older config.
func SetNotifyKafka(s config.Config, name string, cfg target.KafkaArgs) error {
	if !cfg.Enable {
		return nil
	}

	if err := cfg.Validate(); err != nil {
		return err
	}