文件名称：KafkaMiddleWare:利用kafka开发的一个中间件，其可以根据配置创建topic，向指定的topic中发送消息以及消费消息。其可打包供生产端和消费端调用
文件大小：54KB
文件格式：ZIP
更新时间：2024-05-19 07:58:16
KafkaMiddleWare 利用kafka开发的一个中间件，其可以根据配置创建topic，向指定的topic中发送消息以及消费消息。其可打包供生产端和消费端调用。 使用方式： 首先按DataQualityMessage类生产数据，然后可按照测试文件中DataQualityProducerTest.Java文件形式调用生产者；按照DataQualityConsumerTest.java文件形式调用消费者。 当然建议自己修改DataQualityMessage类，修改成自己需要的产生消息的形式（也可直接为String），再打包成中间件由生产和消费端调用。
【文件预览】：
KafkaMiddleWare-master
----.gitignore(1KB)
----README.md(579B)
----pom.xml(4KB)
----kafkaUtil.iml(3KB)
----target()
--------maven-archiver()
--------surefire()
--------maven-status()
--------surefire-reports()
----conf()
--------log4j.properties(739B)
--------config-system.properties(191B)
--------kafka-dataQualityProducer.properties(1KB)
--------kafka-generalProducer.properties(497B)
--------kafka-dataQualityConsumer.properties(1KB)
--------config-topic.xml(738B)
----src()
--------test()
--------main()
----.idea()
--------encodings.xml(555B)
--------vcs.xml(180B)
--------misc.xml(1KB)
--------modules.xml(258B)
--------.name(9B)
--------copyright()
--------inspectionProfiles()
--------codeStyleSettings.xml(393B)
--------compiler.xml(1KB)
--------codeStyles()