获取批量消息并提交,如果批量操作成功

无法实现以下流程: 1. 从 Kafka 中读取批量消息。 2. 处理所有消息。 3. 如果所有消息处理成功 - 提交偏移量。 4. 如果任何消息处理失败 - 不要提交偏移量, 并再次读取同一批消息, 尝试处理这些消息, 如果成功, 则提交偏移量。