文件名称:flume_kafka_sink:卡夫卡水槽
文件大小:10KB
文件格式:ZIP
更新时间:2024-06-11 12:00:46
Java
kafkaSink.type = com.zyy.bi.flume.sink.KafkaSink kafkaSink.channel = kafkaSink.metadata.broker.list = kafkaSink.topic = custom.partition.key = Flume事件标头custom.encoding =事件主体编码
【文件预览】:
flume_kafka_sink-master
----.project(545B)
----.gitattributes(378B)
----src()
--------test()
--------main()
----.settings()
--------org.eclipse.m2e.core.prefs(116B)
--------org.eclipse.jdt.core.prefs(268B)
--------com.genuitec.eclipse.j2eedt.core.prefs(84B)
----.myumldata(64B)
----README.md(203B)
----pom.xml(1KB)
----.classpath(500B)
----.gitignore(574B)