文件名称：Kafka创建Topic，还有生产者消费者按照FileBeat格式通信
文件大小：22KB
文件格式：ZIP
更新时间：2022-06-13 04:02:53
Kafka zkutil zookeeper java
需求： 能力申请提交成功后，自动根据标识ID创建对应Kafka的Topic。 设计思路： 1、在Java代码中调用ZooKeeper的工具类，创建Topic。 2、建立一个含有Topic属性的JavaBean，set内容到各个属性中。 3、Id的规则尚不明确，目前用yyyy-MM-dd日期格式代替id，作为命名后缀。 4、前缀目前在代码中直接定义，后期可以根据需要改为从配置文件或者数据库表中获取。 5、完整代码见附件，包含消费者和生产者的java直接调用获取。
【文件预览】：
SendToKafka
----.project(1KB)
----src()
--------com()
--------main()
----target()
--------m2e-wtp()
--------classes()
--------test-classes()
----.settings()
--------org.eclipse.wst.jsdt.ui.superType.container(49B)
--------org.eclipse.wst.common.project.facet.core.xml(252B)
--------org.eclipse.m2e.core.prefs(86B)
--------org.eclipse.jdt.core.prefs(723B)
--------org.eclipse.wst.validation.prefs(48B)
--------org.eclipse.wst.jsdt.ui.superType.name(6B)
--------org.eclipse.wst.common.component(735B)
--------.jsdtscope(562B)
----pom.xml(6KB)
----.classpath(699B)
----bin()