Bonsai に Elasticsearch クラスターをセットアップしました。ライブラリを使用してelasticsearch-rest-high-level-client
、Kafka に保存されている Twitter ツイートを読み取り、それらを Elasticsearch インデックスにプッシュしています。
私は例外を下回っています:
Exception in thread "main" ElasticsearchStatusException[Elasticsearch exception [type=illegal_argument_exception, reason=Limit of mapping depth [20] in index [twitter] has been exceeded due to object field [THIS CONTAINS ALL OF THE JSON MESSAGE RETRIEVED FROM KAFKA]
私のコードは、すべてのメッセージを単一のフィールドに入れようとしているようです。何がうまくいかないのですか?
IndexRequest indexRequest = new IndexRequest("twitter").source(jsonMessage, XContentType.JSON);
IndexResponse indexResponse = restClient.index(indexRequest, RequestOptions.DEFAULT);