File tree Expand file tree Collapse file tree 4 files changed +5
-10
lines changed
main/java/io/confluent/connect/elasticsearch
test/java/io/confluent/connect/elasticsearch Expand file tree Collapse file tree 4 files changed +5
-10
lines changed Original file line number Diff line number Diff line change 55 <parent >
66 <groupId >io.confluent</groupId >
77 <artifactId >common</artifactId >
8- <version >6.0.0 </version >
8+ <version >6.1.16-32 </version >
99 </parent >
1010
1111 <groupId >io.confluent</groupId >
5252 <confluent .maven.repo>http://packages.confluent.io/maven/</confluent .maven.repo>
5353 <commons .codec.version>1.15</commons .codec.version>
5454 <snakeyaml .version>1.28</snakeyaml .version>
55+ <confluent .version>6.1.15</confluent .version>
5556 </properties >
5657
5758 <repositories >
5859 <repository >
5960 <id >confluent</id >
6061 <name >Confluent</name >
61- <url >http ://packages.confluent.io/maven/</url >
62+ <url >https ://packages.confluent.io/maven/</url >
6263 </repository >
6364 </repositories >
6465
156157 <type >test-jar</type >
157158 <scope >test</scope >
158159 </dependency >
159- <!-- Use a repackaged version of log4j with security patches. Default log4j v1.2 is a transitive dependency of connect-runtime, but it is excluded in common/pom.xml -->
160- <dependency >
161- <groupId >io.confluent</groupId >
162- <artifactId >confluent-log4j</artifactId >
163- <scope >test</scope >
164- </dependency >
165160 <dependency >
166161 <groupId >org.apache.kafka</groupId >
167162 <artifactId >connect-runtime</artifactId >
Original file line number Diff line number Diff line change @@ -58,7 +58,6 @@ public static BulkResponse success() {
5858 * @param retriable whether the error is retriable
5959 * @param errorInfo the error string
6060 * @param failedRecords map of failed records and their results. Never null.
61- * @return
6261 */
6362 public static BulkResponse failure (
6463 boolean retriable ,
Original file line number Diff line number Diff line change @@ -193,7 +193,7 @@ public static HttpClientConfig getClientConfig(ElasticsearchSinkConnectorConfig
193193 builder .defaultCredentials (config .username (), config .password ().value ())
194194 .preemptiveAuthTargetHosts (
195195 addresses .stream ().map (addr -> HttpHost .create (addr )).collect (Collectors .toSet ())
196- );
196+ );
197197 }
198198
199199 configureProxy (config , builder );
Original file line number Diff line number Diff line change 3838import static org .mockito .Mockito .mock ;
3939import static org .mockito .Mockito .when ;
4040
41+ @ SuppressWarnings ("deprecation" )
4142public class MappingTest extends ElasticsearchSinkTestBase {
4243
4344 private static final String INDEX = "kafka-connect" ;
You can’t perform that action at this time.
0 commit comments