一 生产者源码(客户端)初始化发送信息二 消费者源码(客户端) 初始化订阅主题消费者拉取&处理数据消费者offset提交三 服务端源码(服务端) 一 生产者源码(客户端)初始化发送信息二 消费者源码(客户端) 初始化订阅主题消费者拉取&处理数据消费者offset提交三 服务端源码(服务端)