kafka2hdfs_CodingPark

时间:2023-06-06 13:26:46
【文件属性】:

文件名称:kafka2hdfs_CodingPark

文件大小:45.29MB

文件格式:ZIP

更新时间:2023-06-06 13:26:46

kafka HDFS

主要完成 kafka 生产数据、接数据 、通过Java代码上传数据的完整流程 文件包括:hdfstest.java、kafkatest.java、Producer.java、NewConsumer.java、NewConsumer2HDFS.java


【文件预览】:
自动提交偏移量.mp4
kafka514
----pom.xml(4KB)
----target()
--------generated-sources()
--------classes()
----kafka514.iml(80B)
----src()
--------test()
--------main()
--------.DS_Store(6KB)
----.idea()
--------uiDesigner.xml(9KB)
--------$PRODUCT_WORKSPACE_FILE$(489B)
--------workspace.xml(5KB)
--------misc.xml(513B)
--------compiler.xml(529B)
----.DS_Store(6KB)
kafka2hdfs.mp4
指定分区进行消费.mp4
手动提交偏移量.mp4

网友评论