使用spring boot使用kafka消息和post to rest api

tmb3ates  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(355)

我有以下的要求,以实现在 Spring 开机。
如何做到这一点?
使用来自主题的消息并转换RESTAPI的消息字段
通过http或https将其发布到restapi。
捕获api响应。
在发布消息时记录所有错误。

ryevplcw

ryevplcw1#

您可以使用带有kafka活页夹的springkafka或springcloudstream来接收消息。它将反序列化它,然后你可以把它转换成你想要的对象。然后可以使用(inject)restemplate(或webclient for reactive)发布消息。它将发送消息并接收响应。对于错误处理,您可以通过try/catch使用默认的错误处理,或者通过实现 ResponseErrorHandler .
一些有用的链接:
REST模板
resttemplate错误处理
Spring Kafka

相关问题