a17824: 请问作者是在哪里看到关于jupyter进度条的解释的

qq_43301530: 你看看你的标题和你写的内容对的上吗，看你写的东西整个人都是懵逼的

点滴笔记: 尴尬， 着实未明白捕获异常中提交消费事务是指什么？ 如果消费kafka队列中消息解析失败导致异常，将该失败消息写入新的特殊队列以备后续重试消费再次写入DB库中，还是直接将解析失败的消息当做脏数据，捕获异常，写入到DB库中。 按照我的浅解，脏数据场景下，消费异常脏数据后，应该记录当前脏数据且提交脏数据事务消费记录。 如果从kafka消费事务角度看， 其它消费者仍然可能重复消费并解析失败。 不管是跨分区或者单分区消费的话。 当然， 脏数据从生产端点开始是如何产生的， 这个就得另论了。

坏蛋damn: 写得非常好，有自己的思考，学RocketMQ发现有死信，回过头来对比kafka，很好的文章。我想问下楼主，如果kafka有一条脏消息由于json解析失败，导致消费者始终都不会提交，那么这条消息永远在队列前面，后面的消息消费不了，这样在业务代码中消费者需要在异常捕获中提交消费事务吗？

圆周率的后六位: 是呢，在工作中我也遇到过这个问题。