好问题！我之前用confluent_kafka开发时也踩过硬编码错误码的坑，其实官方客户端早就给我们准备好了对应的常量，完全不用写死-190这种数值。

正确处理方法： #

• 首先要导入confluent_kafka里的KafkaError类，它封装了所有预定义的Kafka错误码常量，不用自己去记那些晦涩的数值。
• 你遇到的_UNKNOWN_PARTITION错误，对应的常量就是KafkaError.UNKNOWN_PARTITION，直接用这个常量和错误码对比就可以了。

修改后的代码示例： #

from confluent_kafka import KafkaException, KafkaError

# 你的其他业务代码...

try:
    earliest_offsets = self._kafka.offsets_for_times(topic_partitions)
except KafkaException as exception:
    kafka_error = exception.args[0]
    if kafka_error.code() == KafkaError.UNKNOWN_PARTITION:
        print("Kafka Topic/Partition Does Not Exist!!")
    else:
        # 针对其他类型的Kafka异常做处理，或者直接抛出
        raise

额外小技巧： #

如果以后碰到其他陌生的错误码，直接打印dir(KafkaError)就能列出所有可用的错误常量，轻松找到对应场景的常量，彻底告别硬编码数值的维护隐患。

内容的提问来源于stack exchange，提问作者ScaryAardvark