可以将 ElasticSearchIO.java 源码拷贝至自己的项目. 改名为 MyElasticSearchIO.java. 自己定制实现. 这时编译会遇到 auto.value 失败. 在 pom.xml 中加入如下依赖:
- <!-- googles -->
- <!-- https://mvnrepository.com/artifact/com.google.auto.value/auto-value -->
- <dependency>
- <groupId>com.google.auto.value</groupId>
- <artifactId>auto-value</artifactId>
- <version>1.6.3</version>
- <scope>provided</scope>
- </dependency>
- <!-- https://mvnrepository.com/artifact/com.google.guava/guava -->
- <dependency>
- <groupId>com.google.guava</groupId>
- <artifactId>guava</artifactId>
- <version>27.0.1-jre</version>
- </dependency>
报错是在 flushBatch 里面的 checkForErrors 出现.
来源: http://www.bubuko.com/infodetail-2898939.html