파이썬은 여기 내 코드의 일부입니다 confluent_kafka

의 KafkaException를 잡을 수 없습니다. 두 개의 서버를 하나씩 다시 시작하면 KafkaProducer.send()가 KafkaException (아마도 confluent_kafka의 일부 버그)을 throw하고 일부 예외 로그가 발생합니다.파이썬은 여기 내 코드의 일부입니다 confluent_kafka

이상한 점은 scan_new_application에서 예외가 계속 나오고 run_scan_new_application에도 예외 로그가 있다는 것입니다. 심지어 스레드 stopped.Here 예외 로그 : 그것은 (현재) 요청 된 주제 클러스터에 존재하지 않는 알고 (자동 항목 생성 비활성화) 때문에

2017-12-21 07:11:49 INFO pre_risk_control_flow.py:71 pid-16984 scan_new_application starts at 1513840309.6 
2017-12-21 07:11:49 ERROR new_application_scan.py:165 pid-16984 Traceback (most recent call last): 
    File "/home/ubuntu/data/code/risk/Feature_Engine/data_retrive/pre_risk_control_flow/new_application_scan.py", line 163, in scan_new_application 
    {"uid": uid, "country_id": user_info[1], "event_id": constant.RISK_EVENT_NEW_APPLICATION}) 
    File "/home/ubuntu/data/code/risk/Feature_Engine/data_retrive/kafka_client/Producer.py", line 27, in send 
    cls.producer.produce(topic, json.dumps(data), key) 
KafkaException: KafkaError{code=_UNKNOWN_TOPIC,val=-188,str="Unable to produce message: Local: Unknown topic"} 

2017-12-21 07:11:49 ERROR pre_risk_control_flow.py:75 pid-16984 new_application_scanner Error:KafkaError{code=_UNKNOWN_TOPIC,val=-188,str="Unable to produce message: Local: Unknown topic"}

출처

2017-12-22 moon

기본이되는 클라이언트는 KafkaException KafkaError{code=_UNKNOWN_TOPIC..}을 제기한다. 이것은 예상된다.

을 send()에 잡아 내지 못했기 때문에 run_scan_new_application에 예외가 표시됩니다.

출처

2018-01-15 07:09:23 Edenhill

파이썬은 여기 내 코드의 일부입니다 confluent_kafka

답변

관련 문제