java向kafka事件订阅rest api
我最近开始为我的一个项目研究卡夫卡
我想弄清楚,我如何才能订阅一个Kafka事件的restapi,而不是运行一个一直在听这个主题的消费者
我遇到了卡夫卡连接,但无法准确地找出如何实现同样的目标
详细信息:我以制作人的身份运行一个spring引导项目,该项目使用spring提供的KafkaTemplate发布消息。此外,使用者是一个Spring引导项目,它公开restapi
你可以在下面搜索框中键入要查询的问题!
我最近开始为我的一个项目研究卡夫卡
我想弄清楚,我如何才能订阅一个Kafka事件的restapi,而不是运行一个一直在听这个主题的消费者
我遇到了卡夫卡连接,但无法准确地找出如何实现同样的目标
详细信息:我以制作人的身份运行一个spring引导项目,该项目使用spring提供的KafkaTemplate发布消息。此外,使用者是一个Spring引导项目,它公开restapi
# 1 楼答案
只有使用卡夫卡消费者库才能从卡夫卡获取数据。卡夫卡连接也会这样做
RESTful服务是无状态的。拥有一个消费者更有状态(例如,补偿维护)
如果您想要一般的流式事件,也许您可以查看WebSocket或gRPC