@Before public void before() { ctx.setName("testctx"); ctx.setStatusManager(new BasicStatusManager()); unit.setContext(ctx); unit.setName("kafkaAppenderBase"); unit.setEncoder(encoder); unit.setTopic("topic"); unit.addProducerConfig("bootstrap.servers=localhost:1234"); unit.setKeyingStrategy(keyingStrategy); unit.setDeliveryStrategy(deliveryStrategy); ctx.start(); }
@Before public void before() { loggerContext.setName("testctx"); loggerContext.setStatusManager(new BasicStatusManager()); nifiAppender.setContext(loggerContext); nifiAppender.setName("NifiAppender"); nifiAppender.setUrl("http://localhost:8000/nifi/"); nifiAppender.setReceiverPortName("FromLogback"); nifiAppender.setReceiverPortId("3f5c5ece-4e8f-1c7f-ffff-ffff8a1f130b"); nifiAppender.setPushInterval(10); nifiAppender.setSiteToSiteTransportProtocol("HTTP"); loggerContext.start(); }