我有以下的要求，以实现在 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