Выходные сообщения Flink иногда никогда не доходят до Кафки [закрыто] ⇐ Python

[Anonymous]

после знакомства с этими KIP:

https://cwiki.apache.org/confluence/dis ... ion+in+2PC.
https://cwiki.apache.org/confluence/dis ... de+Defense
кроме того, что мы просим нашу команду Kafka искать ошибки тайм-аута, задаемся вопросом, с чего начать, где мы делаем этот вызов (из удаленного состояния/FastAPI-statefun), но он - иногда - никогда не достигает Тема Кафки:
context.send_egress(
kafka_egress_message(
typename=settings.OUR_TYPE,
topic=settings.OUR_TOPIC,
key=state.session_id,
value=evaluation_data_egress,
value_type=EvaluationDataEgressType,
)
)


Подробнее здесь: https://stackoverflow.com/questions/798 ... t-to-kafka