【文件属性】：
文件名称：gd-kafka-batch-capstone:gd-kafka-批处理-capstone
文件大小：74.82MB
文件格式：ZIP
更新时间：2021-04-05 13:38:14
Java
如何开始
1.启动容器
cd containers
docker-compose up -d
2.在领事中注册kafka和postgres
cd containers
./register.sh
3.迁移架构
cd flyway
mvn flyway:migrate
4.运行应用
如果您正在IntelliJ IDEA中运行应用程序，请打开ProducerApplication的“运行配置”，然后将“工作目录”设置为$MODULE_WORKING_DIR$
5.复制生产者应用程序的文件
下载或从data/archive文件夹中获取一些文件，然后将其移至data/inbound 。 文件应由生产者应用程序捕获，并发布给Kafka经纪人。 消费者应接收它们并将其保存到数据库中
6.在数据库中填充了一些数据之后，通过打开以下URL运行批处理作业：
http://localhost:11003/
【文件预览】：
gd-kafka-batch-capstone-master
----grid-mkurbatov-capstone-project.iml(80B)
----pom.xml(701B)
----analyzer()
--------pom.xml(4KB)
--------src()
--------.gitignore(333B)
----data()
--------archive()
----consumer()
--------pom.xml(4KB)
--------src()
--------.gitignore(333B)
----containers()
--------consul-services()
--------register.sh(162B)
--------docker-compose.yml(1008B)
----.idea()
--------dataSources.xml(491B)
--------uiDesigner.xml(9KB)
--------misc.xml(705B)
--------vcs.xml(180B)
--------encodings.xml(680B)
--------compiler.xml(1KB)
--------.gitignore(117B)
--------sqldialects.xml(2KB)
----common()
--------pom.xml(1KB)
--------src()
--------.gitignore(333B)
----producer()
--------pom.xml(4KB)
--------src()
--------.gitignore(333B)
----flyway()
--------pom.xml(2KB)
--------flyway.iml(80B)
--------src()
----README.md(1KB)