quarkus-kafka-demo

时间:2024-04-21 15:56:35
【文件属性】:

文件名称: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)

网友评论