我已经在数千个网站上搜索了用java语言编写的play框架中的kafka消费者示例。但找不到任何例子。有谁能提供关于如何编写一个持续使用Kafka制作的主题的服务的细节吗。谢谢
5hcedyr01#
play是一个web框架。底层的参与者系统依赖于akka。akkafkaapi名为alpakka,因此我怀疑您搜索的关键字是错误的要结合使用akka和play w/kafka,甚至可以使用lagom框架否则,您当然也可以使用普通java消费者,而不考虑play框架提供有关如何编写服务的详细信息,该服务将持续使用Kafka制作的主题
KafkaConsumer c = new KafkaConsumer(props); while (true) { ConsumerRecords r = c.poll(1000); ... }
1条答案
按热度按时间5hcedyr01#
play是一个web框架。底层的参与者系统依赖于akka。
akkafkaapi名为alpakka,因此我怀疑您搜索的关键字是错误的
要结合使用akka和play w/kafka,甚至可以使用lagom框架
否则,您当然也可以使用普通java消费者,而不考虑play框架
提供有关如何编写服务的详细信息,该服务将持续使用Kafka制作的主题