Я создал собственный appender для потоковой передачи событий журнала в Kafka.
Как мне издеваться над приложением kafka и тестировать метод @PluginFactory?
Вот мой метод, который я хотел бы проверить с помощью Junit.
@PluginFactory
public static KafkaAppender createAppender(@PluginAttribute("name") final String name,
@PluginElement("Filter") final Filter filter,
@PluginAttribute("ignoreExceptions") final String ignore,
@PluginAttribute("topic") @Required final String topic,
@PluginAttribute("enable") String enable,
@PluginAttribute("syncsend") String syncsend,
@PluginElement("Layout") Layout<? extends Serializable> layout,
@PluginElement("Properties") final Property[] properties) {
}
Оцените, еслиВы могли бы указать мне на некоторый пример.