文件名称:
Kafka创建Topic，还有生产者消费者按照FileBeat格式通信
开发工具:
文件大小: 22kb
下载次数: 0
上传时间: 2019-05-24
详细说明： 需求： 能力申请提交成功后，自动根据标识ID创建对应Kafka的Topic。 设计思路： 1、在Java代码中调用ZooKeeper的工具类，创建Topic。 2、建立一个含有Topic属性的JavaBean，set内容到各个属性中。 3、Id的规则尚不明确，目前用yyyy-MM-dd日期格式代替id，作为命名后缀。 4、前缀目前在代码中直接定义，后期可以根据需要改为从配置文件或者数据库表中获取。 5、完整代码见附件，包含消费者和生产者的java直接调用获取。
(系统自动生成,下载前可以参看下载内容)
下载文件列表
相关说明
- 本站资源为会员上传分享交流与学习,如有侵犯您的权益,请联系我们删除.
- 本站是交换下载平台，提供交流渠道，下载内容来自于网络，除下载问题外，其它问题请自行百度。
- 本站已设置防盗链，请勿用迅雷、QQ旋风等多线程下载软件下载资源，下载后用WinRAR最新版进行解压.
- 如果您发现内容无法下载，请稍后再次尝试；或者到消费记录里找到下载记录反馈给我们.
- 下载后发现下载的内容跟说明不相乎，请到消费记录里找到下载记录反馈给我们，经确认后退回积分.
- 如下载前有疑问，可以通过点击"提供者"的名字，查看对方的联系方式，联系对方咨询.
相关搜索:
