У меня есть несколько болтов, расширяющих BaseRichBolt в моей топологии. Мы используем KafkaSpout для чтения сообщений из Kafka topi c, а затем сообщения передаются другим болтам. Кортежи терпят неудачу после истечения времени ожидания, даже после того, как последний Болт успешно создал записи в базе данных.
Я понятия не имею, где мне следует ее устранять. Какие-либо мнения о возможных причинах такого поведения?