文件名称:quarkus-kafka-demo
文件大小:69KB
文件格式:ZIP
更新时间:2024-04-21 15:56:35
Java
Quarkus Kafka快速入门 演示Kafka生产者应用程序。 使用MicroProfile Reactive Messaging库作为客户端。 卡夫卡集群 首先,您需要一个Kafka集群。 您可以按照的说明进行操作,或者如果在计算机上安装了docker docker-compose up则可以运行docker-compose up 。 启动应用程序 可以使用以下命令启动该应用程序: mvn quarkus:dev 终点 GET /records :查看自上次对此端点发出请求以来处理的成功和失败消息的数量。 可以每秒调用一次,以大致了解性能。 POST /records -d "{ \"num\": \"1000\", \"payload\": $data }" -H "Content-Type: application/json" :触发将消息批量发送到kafka,其中$n
【文件预览】:
quarkus-kafka-demo-main
----pom.xml(6KB)
----mvnw(10KB)
----docker-compose.yaml(836B)
----src()
--------main()
----.gitignore(317B)
----.dockerignore(53B)
----.mvn()
--------wrapper()
----README.md(2KB)
----mvnw.cmd(6KB)