Incompatible Log4J version about log4j2-elasticsearch HOT 10 CLOSED

    <RollingRandomAccessFile name="File" fileName="logs/latest.log" filePattern="logs/%d{yyyy-MM-dd}-%i.log.gz">
        <PatternLayout>
            <LoggerNamePatternSelector defaultPattern="[%d{HH:mm:ss}] [%t/%level]: [%logger] %minecraftFormatting{%msg}{strip}%n">
                <!-- Log root, Minecraft, Mojang and Bukkit loggers without prefix -->
                <!-- Disable prefix for various plugins that bypass the plugin logger -->
                <PatternMatch key=",net.minecraft.,Minecraft,com.mojang.,com.sk89q.,ru.tehkode.,Minecraft.AWE"
                              pattern="[%d{HH:mm:ss}] [%t/%level]: %minecraftFormatting{%msg}{strip}%n" />
            </LoggerNamePatternSelector>
        </PatternLayout>
        <Policies>
            <TimeBasedTriggeringPolicy />
            <OnStartupTriggeringPolicy />
        </Policies>
        <DefaultRolloverStrategy max="1000"/>
    </RollingRandomAccessFile>

public void onLoad() {
    instance = this;

    Logger logger = MinecraftServer.LOGGER;
    org.apache.logging.log4j.core.Logger coreLogger = (org.apache.logging.log4j.core.Logger)logger;
    createLoggerProgrammatically(coreLogger, createElasticsearchAppenderBuilder(coreLogger, false), Configuration::getAsyncLoggerConfigDelegate);
    logger.info("test message");
}


public  ElasticsearchAppender.Builder createElasticsearchAppenderBuilder(org.apache.logging.log4j.core.Logger coreLogger, boolean messageOnly) {

    JestHttpObjectFactory.Builder jestHttpObjectFactoryBuilder;
    jestHttpObjectFactoryBuilder = JestHttpObjectFactory.newBuilder();

    jestHttpObjectFactoryBuilder.withConnTimeout(1000)
            .withReadTimeout(10000)
            .withIoThreadCount(8)
            .withDefaultMaxTotalConnectionPerRoute(8)
            .withMaxTotalConnection(8)
            .withMappingType("_doc");

    jestHttpObjectFactoryBuilder.withServerUris(hostname);

    IndexTemplate indexTemplate = new IndexTemplate.Builder()
            .withName("log4j2_test_jest")
            .withSource(loadClasspathResource("classpath:indexTemplate.json"))
            .build();

    BatchDelivery asyncBatchDelivery = new SpigotAsyncBatchDelivery(BATCH_SIZE + ADDITIONAL_BATCH_SIZE, 1000, jestHttpObjectFactoryBuilder.build(), AsyncBatchDelivery.Builder.DEFAULT_FAILOVER_POLICY, indexTemplate);

    IndexNameFormatter indexNameFormatter = RollingIndexNameFormatter.newBuilder()
            .withIndexName("log4j2_test_jest")
            .withPattern("yyyy-MM-dd-HH")
            .build();

    return ElasticsearchAppender.newBuilder()
            .withName("elastic-appender")
            .withMessageOnly(messageOnly)
            .withBatchDelivery(asyncBatchDelivery)
            .withIndexNameFormatter(indexNameFormatter)
            .withLayout((AbstractLayout) coreLogger.getContext().getConfiguration().getAppender("File").getLayout())
            .withIgnoreExceptions(false);
}

public void createLoggerProgrammatically(org.apache.logging.log4j.core.Logger coreLogger, ElasticsearchAppender.Builder appenderBuilder, Function<Configuration, AsyncLoggerConfigDelegate> delegateSupplier) {

    LoggerContext ctx = coreLogger.getContext();

    final Configuration config = ctx.getConfiguration();

    Appender appender = appenderBuilder.build();
    appender.start();

    ((LifeCycle2)delegateSupplier.apply(config)).start();

    config.addAppender(appender);
}

public class SpigotAsyncBatchDelivery extends AsyncBatchDelivery {

    public SpigotAsyncBatchDelivery(int batchSize, int deliveryInterval, ClientObjectFactory objectFactory, FailoverPolicy failoverPolicy, IndexTemplate indexTemplate) {
        super(batchSize, deliveryInterval, objectFactory, failoverPolicy, indexTemplate);
    }

    @Override
    protected BatchEmitterServiceProvider createBatchEmitterServiceProvider() {
        return new SpigotBatchEmitterServiceProvider();
    }
}

public class SpigotBatchEmitterServiceProvider extends BatchEmitterServiceProvider{

    private final Logger LOG = StatusLogger.getLogger();

    @Override
    public BatchEmitter createInstance(int batchSize, int deliveryInterval, ClientObjectFactory clientObjectFactory, FailoverPolicy failoverPolicy) {
        BatchEmitterFactory factory = new BulkEmitterFactory(); //Service#load not supported
        LOG.info("BatchEmitterFactory class found {}", factory.getClass().getName());
        if (factory.accepts(clientObjectFactory.getClass())) {
            LOG.info("Using {} as BatchEmitterFactoryProvider", factory);
            return factory.createInstance(batchSize, deliveryInterval, clientObjectFactory, failoverPolicy);
        }
        throw new ConfigurationException(String.format("No compatible BatchEmitter implementations for %s found", clientObjectFactory.getClass().getName()));
    }
}