From ebc0adcedf5a3ec3c13739231ea4243957c9bb66 Mon Sep 17 00:00:00 2001 From: Gunnar Morling Date: Fri, 9 Aug 2019 09:15:54 +0200 Subject: [PATCH] DBZ-1424 Removing unused dependencies from Cassandra connector; Also referring to managed version for Avro serializer. --- debezium-connector-cassandra/pom.xml | 12 +------ .../connector/cassandra/TestUtils.java | 34 ------------------- 2 files changed, 1 insertion(+), 45 deletions(-) delete mode 100644 debezium-connector-cassandra/src/test/java/io/debezium/connector/cassandra/TestUtils.java diff --git a/debezium-connector-cassandra/pom.xml b/debezium-connector-cassandra/pom.xml index 16c2dfd1a..7e859cedb 100644 --- a/debezium-connector-cassandra/pom.xml +++ b/debezium-connector-cassandra/pom.xml @@ -24,7 +24,7 @@ io.confluent kafka-avro-serializer - 5.1.2 + ${version.confluent.platform} com.datastax.cassandra @@ -61,16 +61,6 @@ jetty-servlet 9.4.12.v20180830 - - com.google.code.findbugs - annotations - 3.0.1 - - - com.google.cloud - google-cloud-storage - 1.70.0 - diff --git a/debezium-connector-cassandra/src/test/java/io/debezium/connector/cassandra/TestUtils.java b/debezium-connector-cassandra/src/test/java/io/debezium/connector/cassandra/TestUtils.java deleted file mode 100644 index 4c90106bc..000000000 --- a/debezium-connector-cassandra/src/test/java/io/debezium/connector/cassandra/TestUtils.java +++ /dev/null @@ -1,34 +0,0 @@ -/* - * Copyright Debezium Authors. - * - * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 - */ -package io.debezium.connector.cassandra; - -import com.google.api.client.googleapis.json.GoogleJsonError; -import com.google.api.client.googleapis.json.GoogleJsonResponseException; -import com.google.api.client.http.HttpHeaders; -import com.google.api.client.http.HttpResponseException; -import com.google.cloud.storage.StorageException; - -/** - * Miscellaneous utility methods for unit testing. - */ -public final class TestUtils { - - private TestUtils() { } - - /** - * Generate a {@link StorageException} with a specified error code - * @param code error code - * @return a storage exception - */ - public static StorageException generateGoogleStorageException(int code) { - GoogleJsonError jsonError = new GoogleJsonError(); - jsonError.setCode(code); - jsonError.setMessage("n/a"); - HttpResponseException.Builder builder = new HttpResponseException.Builder(code, "n/a", new HttpHeaders()); - GoogleJsonResponseException jsonResponseException = new GoogleJsonResponseException(builder, jsonError); - return new StorageException(jsonResponseException); - } -}