如何从apachekafka调用springboot服务端点并传递来自主题的所有消息？

rfbsl7qr 于 2021-06-04 发布在 Kafka

关注(0)|答案(1)|浏览(334)

我是Kafka技术的新手，我需要从数据库中获取所有实时数据，并将其传递给springboot微服务进行处理。在我的分析中发现，带有kafka源connect的apachekafka可以将db中的所有实时数据拉到kafka主题中。有人能告诉我有没有办法从kafka主题中选取这些数据，并通过触发kafka服务的restcall来共享给microservice？这个想法是每当一个新的条目添加到数据库表kafka可以通过kafka connect拉取数据时，kafka应该调用微服务并共享这个新条目。Kafka有可能吗？
数据库-->Kafka连接-->Kafka（主题）-->一些调用微服务的服务-->微服务

apache-kafka apache-kafka-connect

来源：https://stackoverflow.com/questions/63953738/how-to-call-a-springboot-service-endpoint-from-apache-kafka-and-pass-all-the-mes

1条答案

按热度按时间

ztmd8pv51#

形成Kafka主题并分享给微服务
Kafka不推。您可以在您的服务中添加一个consumer来从kafka中提取，也许可以使用 spring-kafka 或者 spring-cloud-streams 或者，kafka connect sink可以与httppost连接器一起使用，但是您需要以某种方式处理不提交请求失败的消息的偏移量的问题。

赞(0）回复(0）举报 2021-06-04

我来回答

如何从apachekafka调用springboot服务端点并传递来自主题的所有消息？

1条答案

相关问题

热门标签

最新问答