#apache-kafka #spark-streaming
#apache-kafka #spark-streaming
Вопрос:
Я думаю, что в теме с несколькими разделами, если один из разделов недоступен, остальные все равно могут использоваться нормально. Это правильно?
Если да, то почему он сообщает об этой ошибке при запуске Spark Streaming программы, когда один из разделов недоступен?
Timeout of 60000ms expired before the position for partition [topic_name]-[partition] could be determined
Комментарии:
1. каков фактор тиражирования темы?
2. 500 разделов и коэффициент репликации равен трем.