但是当我尝试创建BulkProcessor时,我遇到了一个问题,我不知道如何将这个示例从Java转换为Scala但是我得到了这个错误:
overloaded method value builder with alternatives)org.elasticsearch.action.bulk.BulkProcessor</
bulkProcessor = BulkProcessor.builder(getClient(), new BulkProcessor.Listener() {
@Override(BulkProcessor.java:312) at org.elasticsearch.action.bulk.BulkProcessor.executeIfNeeded(BulkProcessor.java:303) at org.elasticsearch.action.bulk.<e
search_data] can't be changed from nested to non-nested\"}]\n\tat io.confluent.connect.elasticsearch.bulk.BulkProcessor$BulkTask.handleMalformedDoc(BulkProcessor.java:479)\n\tat io.confluent.connect.elasticsearch.bulk.BulkProcessor$BulkTask.execute(BulkProces
:42:57,532] ERROR Failed to execute batch 127 of 2 records (io.confluent.connect.elasticsearch.bulk.BulkProcessor$BulkTask.execute(BulkProcessor.java:348)
connect_1 | at io.confluent.connect.elasticsearch.bulk.BulkProcessor$BulkTask.call(BulkProcessor.java:326