We are using Storm ESBolt to index documents to Elasticsearch. Our topology is reading the documents from Kafka and indexing them to Elasticsearch using ESBolt.
We have peak periods during the day when the capacity of the ESBolt is over 1 during 30 minutes or 1 hour but the rest of the day its capacity is 0.1. What happens when the ESBolt goes over 1.0 of capacity during 30 minutes or 1 hour? May it drop documents?
We don't have any failed tuples (we have es.storm.bolt.write.ack: true) and we don't have any error/warning message in the worker logs. We have the bolt configured with es.batch.write.refresh: false.