我想从Kafka主题中读取消息（用fastkafka库的consumes装饰器 Package 我的消息处理器）。
但是我不想只自动提交消息，还想手动提交它们--而且只有在消息处理正确的情况下（当我的额外函数处理它们的内部数据时没有抛出任何异常）。
如何才能做到这一点？如何手动提交消息--并且只有在我确实想提交它们的时候才能提交？