我有以下的要求,以实现在 Spring 开机。如何做到这一点?使用来自主题的消息并转换RESTAPI的消息字段通过http或https将其发布到restapi。捕获api响应。在发布消息时记录所有错误。
ryevplcw1#
您可以使用带有kafka活页夹的springkafka或springcloudstream来接收消息。它将反序列化它,然后你可以把它转换成你想要的对象。然后可以使用(inject)restemplate(或webclient for reactive)发布消息。它将发送消息并接收响应。对于错误处理,您可以通过try/catch使用默认的错误处理,或者通过实现 ResponseErrorHandler .一些有用的链接:REST模板resttemplate错误处理Spring Kafka
ResponseErrorHandler
1条答案
按热度按时间ryevplcw1#
您可以使用带有kafka活页夹的springkafka或springcloudstream来接收消息。它将反序列化它,然后你可以把它转换成你想要的对象。然后可以使用(inject)restemplate(或webclient for reactive)发布消息。它将发送消息并接收响应。对于错误处理,您可以通过try/catch使用默认的错误处理,或者通过实现
ResponseErrorHandler
.一些有用的链接:
REST模板
resttemplate错误处理
Spring Kafka