try futuregettimeout=10 # 监控是否发送成功 except kafka_errors as e1 # 发送失败抛出kafka_errors #tracebackformat_exc print发送失败 e1 except kafkaerrorsUnknownTopicOrPar

尝试捕获所有异常，并根据不同的异常类型进行相应的处理。其中，kafka_errors是自定义的异常类型，其他两个异常类型分别是kafka.errors.UnknownTopicOrPartitionError和kafka.errors.UnknownTopicOrPartitionError。如果发生异常，将打印出相应的错误信息。