elasticsearch - 从 Kafka 消费消息并回发到 ES 7.2 时出错

Question

错误 StatusLogger Log4j2 找不到日志记录实现。请将 log4j-core 添加到类路径中。使用 SimpleLogger 记录到控制台...线程“主”中的异常 ElasticsearchStatusException[Elasticsearch 异常 [type=illegal_argument_exception，原因=索引 [twitter] 中的总字段限制 [1000] 已超出]] 在 org.elasticsearch.rest .BytesRestResponse.errorFromXContent(BytesRestResponse.java:176) 在 org.elasticsearch.client.RestHighLevelClient.parseEntity(RestHighLevelClient.java:1933) 在 org.elasticsearch.client.RestHighLevelClient.parseResponseException(RestHighLevelClient.java:1910) 在 org.elasticsearch。 client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1667) 在 org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1624) 在 org.elasticsearch.client。

标签： elasticsearchkafka-consumer-api