网友收藏flume的sink测试赫赫有名-CSDN博客public class MySink extends AbstractSink implements Configurable {//前缀private String prefix;//后缀private String suffix;//创建你logger对象private static final Logger LOG = LoggerFactory.getLogger(Abstr...... 2023-10-11 21:16 评论 0 阅读 阅读全文