So first, I'm still a novice in both apache storm and elasticsearch, so please tell me if i did anything wrong in my code. I'm trying to build a simple topology that takes data from elasticsearch index using ESSpout and sends it to another index using ESBolt. The code can be seen here:
The problem is that my spout cannot get the data from my index. It always terminate with "StringIndexOutOfBoundsException: String index out of range: -1" error.
Any help would be highly appreciated. Thanks.
Edit: updated link