基于虚拟线程构建高性能 Kafka → HTTP 转发服务
做物联网对接时，经常会遇到这种情况：设备数据已经通过 Kafka 流转起来了，第三方平台却只提供 HTTP 接口。写一个消费者，把 JSON 换个格式再 POST 过去，第一版似乎很快就能完成。 真正麻烦的是后面的事：对方超时了怎么办？请求已经成功，本地还没来得及记账就重启了怎么办？早高峰突然堆进来一批消息，又该让它们等在哪里？ ps: 本文的目的是记录一个项目设计过程，便于日后复盘，但暂不提供实际压测指标（如吞吐量、延迟、资源消耗） 本文由AI润色。 ...