go-stash is a high performance, free and open source server-side data processing pipeline that ingests data from Kafka, processes it, and then sends it to ElasticSearch.
{"@timestamp":"2023-03-04T15:00:31.601+08","level":"error","content":"index.go:65 elastic: Error 400 (Bad Request): Validation Failed: 1: this action would add [2] shards, but this cluster currently has [1000]/[1000] maximum normal shards open; [type=validation_exception]\nelastic: Error 400 (Bad Request): Validation Failed: 1: this action would add [2] shards, but this cluster currently has [1000]/[1000] maximum normal shards open; [type=validation_exception]\nelastic: Error 400 (Bad Request): Validation Failed: 1: this action would add [2] shards, but this cluster currently has [1000]/[1000] maximum normal shards open; [type=validation_exception]"}
{"@timestamp":"2023-03-04T15:01:12.190+08","level":"error","content":"writer.go:74 \u0026{validation_exception Validation Failed: 1: this action would add [2] shards, but this cluster currently has [1000]/[1000] maximum normal shards open; false map[] [] [] [] map[] [] \u003cnil\u003e}"}
kevwan
commented
9 months ago
{"@timestamp":"2023-03-04T15:00:31.601+08","level":"error","content":"index.go:65 elastic: Error 400 (Bad Request): Validation Failed: 1: this action would add [2] shards, but this cluster currently has [1000]/[1000] maximum normal shards open; [type=validation_exception]\nelastic: Error 400 (Bad Request): Validation Failed: 1: this action would add [2] shards, but this cluster currently has [1000]/[1000] maximum normal shards open; [type=validation_exception]\nelastic: Error 400 (Bad Request): Validation Failed: 1: this action would add [2] shards, but this cluster currently has [1000]/[1000] maximum normal shards open; [type=validation_exception]"}
{"@timestamp":"2023-03-04T15:01:12.190+08","level":"error","content":"writer.go:74 \u0026{validation_exception Validation Failed: 1: this action would add [2] shards, but this cluster currently has [1000]/[1000] maximum normal shards open; false map[] [] [] [] map[] [] \u003cnil\u003e}"}