偏移量

遗留问题

• 读取时设置偏移量，即从特定偏移量开始读取消息
• 提交特定偏移量，即处理一条消息，提交当条消息