-
0 votesanswersviews
当对kafka的伤害停止时,Flume kafka来源减速
测试完成: 使用复制因子3创建的Kafka主题 . 使用以下配置创建的Flume代理, source type = org.apache.flume.source.kafka.KafkaSource, channel type = SPILLABLEMEMORY, sink type = org.apache.flume.sink.kite.DatasetSink Kafka数据 ...