我需要有一个apachekafka生产者-消费者rest微服务应用程序，其中一旦触发生产者rest端点，我应该立即得到一个确认消息，然后触发此服务的工作流在下一步（等待事件）等待，这将由消费者应用程序触发。我该如何实现这一点？谢谢和问候，阿尔宾
vom3gejh1#
你所看到的技术堆栈是1。dropwizard框架：用于启动rest服务以服务传入的请求2。apache-kafka-java客户机基于触发器生成和使用第1步。请遵循此快速入门dropwizard教程https://www.dropwizard.io/0.9.2/docs/getting-started.html 构建rest服务第二步。在dropwizard的初始化步骤中，启动kafka producer和kafka consumer线程第三步。api支持post端点来接收触发事件。根据它是生产还是消费，api资源可以继续处理事件。
1条答案
按热度按时间vom3gejh1#
你所看到的技术堆栈是1。dropwizard框架：用于启动rest服务以服务传入的请求2。apache-kafka-java客户机基于触发器生成和使用
第1步。请遵循此快速入门dropwizard教程https://www.dropwizard.io/0.9.2/docs/getting-started.html 构建rest服务
第二步。在dropwizard的初始化步骤中，启动kafka producer和kafka consumer线程
第三步。api支持post端点来接收触发事件。根据它是生产还是消费，api资源可以继续处理事件。