使用java的kafka消费者游戏框架

tnkciper  于 2021-06-05  发布在  Kafka
关注(0)|答案(1)|浏览(348)

我已经在数千个网站上搜索了用java语言编写的play框架中的kafka消费者示例。但找不到任何例子。有谁能提供关于如何编写一个持续使用Kafka制作的主题的服务的细节吗。
谢谢

5hcedyr0

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);
    ...
}

相关问题