From 1cbce8dfd314bd636ec4e5ae32c27c5f3e4a210d Mon Sep 17 00:00:00 2001 From: Eric Weaver Date: Wed, 18 Nov 2020 23:56:53 -0500 Subject: [PATCH] Rename package name to themeetgroup Change-Id: Id6214a0add10152bd5e67d27e2fcbb6f4e9e204b --- README.md | 10 +++++----- pom.xml | 10 +++------- .../rabbitmq/CommonRabbitMQConnectorConfig.java | 2 +- .../connect/rabbitmq/sink/RabbitMQSinkConnector.java | 2 +- .../rabbitmq/sink/RabbitMQSinkConnectorConfig.java | 4 ++-- .../rabbitmq/sink/RabbitMQSinkHeaderParser.java | 2 +- .../connect/rabbitmq/sink/RabbitMQSinkTask.java | 4 ++-- .../connect/rabbitmq/source/ConnectConsumer.java | 4 ++-- .../rabbitmq/source/RabbitMQSourceConnector.java | 2 +- .../source/RabbitMQSourceConnectorConfig.java | 6 +++--- .../connect/rabbitmq/source/RabbitMQSourceTask.java | 2 +- .../source/data/BytesSourceMessageConverter.java | 4 ++-- .../rabbitmq/source/data/MessageConverter.java | 12 ++++++------ .../rabbitmq/source/data/SourceMessageConverter.java | 2 +- .../rabbitmq/source/data/SourceRecordBuilder.java | 4 ++-- .../source/data/StringSourceMessageConverter.java | 4 ++-- .../rabbitmq/source/data/MessageConverterTest.java | 2 +- .../rabbitmq/source/data/TransformationTest.java | 2 +- src/test/resources/logback.xml | 2 +- 19 files changed, 38 insertions(+), 42 deletions(-) rename src/main/java/com/github/{jcustenborder => themeetgroup}/kafka/connect/rabbitmq/CommonRabbitMQConnectorConfig.java (99%) rename src/main/java/com/github/{jcustenborder => themeetgroup}/kafka/connect/rabbitmq/sink/RabbitMQSinkConnector.java (96%) rename src/main/java/com/github/{jcustenborder => themeetgroup}/kafka/connect/rabbitmq/sink/RabbitMQSinkConnectorConfig.java (94%) rename src/main/java/com/github/{jcustenborder => themeetgroup}/kafka/connect/rabbitmq/sink/RabbitMQSinkHeaderParser.java (97%) rename src/main/java/com/github/{jcustenborder => themeetgroup}/kafka/connect/rabbitmq/sink/RabbitMQSinkTask.java (95%) rename src/main/java/com/github/{jcustenborder => themeetgroup}/kafka/connect/rabbitmq/source/ConnectConsumer.java (94%) rename src/main/java/com/github/{jcustenborder => themeetgroup}/kafka/connect/rabbitmq/source/RabbitMQSourceConnector.java (96%) rename src/main/java/com/github/{jcustenborder => themeetgroup}/kafka/connect/rabbitmq/source/RabbitMQSourceConnectorConfig.java (93%) rename src/main/java/com/github/{jcustenborder => themeetgroup}/kafka/connect/rabbitmq/source/RabbitMQSourceTask.java (98%) rename src/main/java/com/github/{jcustenborder => themeetgroup}/kafka/connect/rabbitmq/source/data/BytesSourceMessageConverter.java (90%) rename src/main/java/com/github/{jcustenborder => themeetgroup}/kafka/connect/rabbitmq/source/data/MessageConverter.java (97%) rename src/main/java/com/github/{jcustenborder => themeetgroup}/kafka/connect/rabbitmq/source/data/SourceMessageConverter.java (94%) rename src/main/java/com/github/{jcustenborder => themeetgroup}/kafka/connect/rabbitmq/source/data/SourceRecordBuilder.java (94%) rename src/main/java/com/github/{jcustenborder => themeetgroup}/kafka/connect/rabbitmq/source/data/StringSourceMessageConverter.java (91%) rename src/test/java/com/github/{jcustenborder => themeetgroup}/kafka/connect/rabbitmq/source/data/MessageConverterTest.java (98%) rename src/test/java/com/github/{jcustenborder => themeetgroup}/kafka/connect/rabbitmq/source/data/TransformationTest.java (88%) diff --git a/README.md b/README.md index 62886b7..5bb208b 100644 --- a/README.md +++ b/README.md @@ -69,7 +69,7 @@ Converter to compose the Kafka message. *Type:* String -*Default Value:* com.github.jcustenborder.kafka.connect.rabbitmq.source.data.MessageConverter +*Default Value:* com.github.themeetgroup.kafka.connect.rabbitmq.source.data.MessageConverter The virtual host to use when connecting to the broker. See `ConnectionFactory.setVirtualHost(java.lang.String) `_ ##### `rabbitmq.port` @@ -189,7 +189,7 @@ This configuration is used typically along with [standalone mode](http://docs.co ```properties name=RabbitMQSourceConnector1 -connector.class=com.github.jcustenborder.kafka.connect.rabbitmq.source.RabbitMQSourceConnector +connector.class=com.github.themeetgroup.kafka.connect.rabbitmq.source.RabbitMQSourceConnector tasks.max=1 kafka.topic=< Required Configuration > rabbitmq.queue=< Required Configuration > @@ -205,7 +205,7 @@ post the configuration to one the distributed connect worker(s). { "config" : { "name" : "RabbitMQSourceConnector1", - "connector.class" : "com.github.jcustenborder.kafka.connect.rabbitmq.source.RabbitMQSourceConnector", + "connector.class" : "com.github.themeetgroup.kafka.connect.rabbitmq.source.RabbitMQSourceConnector", "tasks.max" : "1", "kafka.topic" : "< Required Configuration >", "rabbitmq.queue" : "< Required Configuration >" @@ -398,7 +398,7 @@ This configuration is used typically along with [standalone mode](http://docs.co ```properties name=RabbitMQSinkConnector1 -connector.class=com.github.jcustenborder.kafka.connect.rabbitmq.sink.RabbitMQSinkConnector +connector.class=com.github.themeetgroup.kafka.connect.rabbitmq.sink.RabbitMQSinkConnector tasks.max=1 topics=< Required Configuration > rabbitmq.exchange=< Required Configuration > @@ -416,7 +416,7 @@ post the configuration to one the distributed connect worker(s). { "config" : { "name" : "RabbitMQSinkConnector1", - "connector.class" : "com.github.jcustenborder.kafka.connect.rabbitmq.sink.RabbitMQSinkConnector", + "connector.class" : "com.github.themeetgroup.kafka.connect.rabbitmq.sink.RabbitMQSinkConnector", "tasks.max" : "1", "topics" : "< Required Configuration >", "rabbitmq.exchange" : "< Required Configuration >", diff --git a/pom.xml b/pom.xml index 05ffb53..d18eca4 100644 --- a/pom.xml +++ b/pom.xml @@ -100,11 +100,9 @@ kafka-connect - jcustenborder - true - https://jcustenborder.github.io/kafka-connect-documentation/ - Jeremy Custenborder - jcustenborder + themeetgroup + The Meet Group + themeetgroup kafka-connect-docker sink @@ -116,8 +114,6 @@ Messaging Kafka Connect RabbitMQ - ${project.issueManagement.url} - Support provided through community involvement. diff --git a/src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/CommonRabbitMQConnectorConfig.java b/src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/CommonRabbitMQConnectorConfig.java similarity index 99% rename from src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/CommonRabbitMQConnectorConfig.java rename to src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/CommonRabbitMQConnectorConfig.java index 0297416..3def007 100644 --- a/src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/CommonRabbitMQConnectorConfig.java +++ b/src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/CommonRabbitMQConnectorConfig.java @@ -13,7 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.github.jcustenborder.kafka.connect.rabbitmq; +package com.github.themeetgroup.kafka.connect.rabbitmq; import com.rabbitmq.client.ConnectionFactory; import org.apache.kafka.common.config.AbstractConfig; diff --git a/src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/sink/RabbitMQSinkConnector.java b/src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/sink/RabbitMQSinkConnector.java similarity index 96% rename from src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/sink/RabbitMQSinkConnector.java rename to src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/sink/RabbitMQSinkConnector.java index c5b5656..e361ee6 100644 --- a/src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/sink/RabbitMQSinkConnector.java +++ b/src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/sink/RabbitMQSinkConnector.java @@ -14,7 +14,7 @@ * limitations under the License. */ -package com.github.jcustenborder.kafka.connect.rabbitmq.sink; +package com.github.themeetgroup.kafka.connect.rabbitmq.sink; import java.util.ArrayList; import java.util.List; diff --git a/src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/sink/RabbitMQSinkConnectorConfig.java b/src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/sink/RabbitMQSinkConnectorConfig.java similarity index 94% rename from src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/sink/RabbitMQSinkConnectorConfig.java rename to src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/sink/RabbitMQSinkConnectorConfig.java index ffbc80f..21497c3 100644 --- a/src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/sink/RabbitMQSinkConnectorConfig.java +++ b/src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/sink/RabbitMQSinkConnectorConfig.java @@ -14,11 +14,11 @@ * limitations under the License. */ -package com.github.jcustenborder.kafka.connect.rabbitmq.sink; +package com.github.themeetgroup.kafka.connect.rabbitmq.sink; import java.util.Map; -import com.github.jcustenborder.kafka.connect.rabbitmq.CommonRabbitMQConnectorConfig; +import com.github.themeetgroup.kafka.connect.rabbitmq.CommonRabbitMQConnectorConfig; import org.apache.kafka.common.config.ConfigDef; import com.github.jcustenborder.kafka.connect.utils.template.StructTemplate; diff --git a/src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/sink/RabbitMQSinkHeaderParser.java b/src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/sink/RabbitMQSinkHeaderParser.java similarity index 97% rename from src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/sink/RabbitMQSinkHeaderParser.java rename to src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/sink/RabbitMQSinkHeaderParser.java index c7052a3..071ce21 100644 --- a/src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/sink/RabbitMQSinkHeaderParser.java +++ b/src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/sink/RabbitMQSinkHeaderParser.java @@ -14,7 +14,7 @@ * limitations under the License. */ -package com.github.jcustenborder.kafka.connect.rabbitmq.sink; +package com.github.themeetgroup.kafka.connect.rabbitmq.sink; import com.rabbitmq.client.AMQP; diff --git a/src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/sink/RabbitMQSinkTask.java b/src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/sink/RabbitMQSinkTask.java similarity index 95% rename from src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/sink/RabbitMQSinkTask.java rename to src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/sink/RabbitMQSinkTask.java index 192d65f..56d2d42 100644 --- a/src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/sink/RabbitMQSinkTask.java +++ b/src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/sink/RabbitMQSinkTask.java @@ -14,7 +14,7 @@ * limitations under the License. */ -package com.github.jcustenborder.kafka.connect.rabbitmq.sink; +package com.github.themeetgroup.kafka.connect.rabbitmq.sink; import com.github.jcustenborder.kafka.connect.utils.VersionUtil; import com.rabbitmq.client.Channel; @@ -32,7 +32,7 @@ import java.util.Map; import java.util.concurrent.TimeoutException; -import static com.github.jcustenborder.kafka.connect.rabbitmq.sink.RabbitMQSinkConnectorConfig.HEADER_CONF; +import static com.github.themeetgroup.kafka.connect.rabbitmq.sink.RabbitMQSinkConnectorConfig.HEADER_CONF; public class RabbitMQSinkTask extends SinkTask { private static final Logger log = LoggerFactory.getLogger(RabbitMQSinkTask.class); diff --git a/src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/source/ConnectConsumer.java b/src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/source/ConnectConsumer.java similarity index 94% rename from src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/source/ConnectConsumer.java rename to src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/source/ConnectConsumer.java index 940799c..f07d0b3 100644 --- a/src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/source/ConnectConsumer.java +++ b/src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/source/ConnectConsumer.java @@ -13,9 +13,9 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.github.jcustenborder.kafka.connect.rabbitmq.source; +package com.github.themeetgroup.kafka.connect.rabbitmq.source; -import com.github.jcustenborder.kafka.connect.rabbitmq.source.data.SourceRecordBuilder; +import com.github.themeetgroup.kafka.connect.rabbitmq.source.data.SourceRecordBuilder; import com.github.jcustenborder.kafka.connect.utils.data.SourceRecordConcurrentLinkedDeque; import com.rabbitmq.client.AMQP; import com.rabbitmq.client.Consumer; diff --git a/src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/source/RabbitMQSourceConnector.java b/src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/source/RabbitMQSourceConnector.java similarity index 96% rename from src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/source/RabbitMQSourceConnector.java rename to src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/source/RabbitMQSourceConnector.java index db0ea57..079546c 100644 --- a/src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/source/RabbitMQSourceConnector.java +++ b/src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/source/RabbitMQSourceConnector.java @@ -13,7 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.github.jcustenborder.kafka.connect.rabbitmq.source; +package com.github.themeetgroup.kafka.connect.rabbitmq.source; import com.github.jcustenborder.kafka.connect.utils.VersionUtil; import com.github.jcustenborder.kafka.connect.utils.config.Description; diff --git a/src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/source/RabbitMQSourceConnectorConfig.java b/src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/source/RabbitMQSourceConnectorConfig.java similarity index 93% rename from src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/source/RabbitMQSourceConnectorConfig.java rename to src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/source/RabbitMQSourceConnectorConfig.java index e0c7ed9..3a1a83b 100644 --- a/src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/source/RabbitMQSourceConnectorConfig.java +++ b/src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/source/RabbitMQSourceConnectorConfig.java @@ -13,9 +13,9 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.github.jcustenborder.kafka.connect.rabbitmq.source; +package com.github.themeetgroup.kafka.connect.rabbitmq.source; -import com.github.jcustenborder.kafka.connect.rabbitmq.CommonRabbitMQConnectorConfig; +import com.github.themeetgroup.kafka.connect.rabbitmq.CommonRabbitMQConnectorConfig; import org.apache.kafka.common.config.ConfigDef; import java.util.List; @@ -40,7 +40,7 @@ public class RabbitMQSourceConnectorConfig extends CommonRabbitMQConnectorConfig public static final String MESSAGE_CONVERTER_CLASSNAME_CONF = "message.converter"; public static final String MESSAGE_CONVERTER_CLASSNAME_DOC = "Converter to compose the Kafka message. Optional, defaults to " + - "com.github.jcustenborder.kafka.connect.rabbitmq.source.data.MessageConverter"; + "com.github.themeetgroup.kafka.connect.rabbitmq.source.data.MessageConverter"; public final String kafkaTopic; public final List queues; diff --git a/src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/source/RabbitMQSourceTask.java b/src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/source/RabbitMQSourceTask.java similarity index 98% rename from src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/source/RabbitMQSourceTask.java rename to src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/source/RabbitMQSourceTask.java index 7cf4022..5f07045 100644 --- a/src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/source/RabbitMQSourceTask.java +++ b/src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/source/RabbitMQSourceTask.java @@ -13,7 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.github.jcustenborder.kafka.connect.rabbitmq.source; +package com.github.themeetgroup.kafka.connect.rabbitmq.source; import com.github.jcustenborder.kafka.connect.utils.VersionUtil; import com.github.jcustenborder.kafka.connect.utils.data.SourceRecordConcurrentLinkedDeque; diff --git a/src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/source/data/BytesSourceMessageConverter.java b/src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/source/data/BytesSourceMessageConverter.java similarity index 90% rename from src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/source/data/BytesSourceMessageConverter.java rename to src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/source/data/BytesSourceMessageConverter.java index 0749dd0..aa3c22f 100644 --- a/src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/source/data/BytesSourceMessageConverter.java +++ b/src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/source/data/BytesSourceMessageConverter.java @@ -13,7 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.github.jcustenborder.kafka.connect.rabbitmq.source.data; +package com.github.themeetgroup.kafka.connect.rabbitmq.source.data; import com.rabbitmq.client.AMQP; import com.rabbitmq.client.Envelope; @@ -21,7 +21,7 @@ import org.apache.kafka.connect.header.ConnectHeaders; import org.apache.kafka.connect.header.Headers; -import static com.github.jcustenborder.kafka.connect.rabbitmq.source.data.MessageConverter.basicProperties; +import static com.github.themeetgroup.kafka.connect.rabbitmq.source.data.MessageConverter.basicProperties; public class BytesSourceMessageConverter implements SourceMessageConverter { diff --git a/src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/source/data/MessageConverter.java b/src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/source/data/MessageConverter.java similarity index 97% rename from src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/source/data/MessageConverter.java rename to src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/source/data/MessageConverter.java index fe60401..b75a8be 100644 --- a/src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/source/data/MessageConverter.java +++ b/src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/source/data/MessageConverter.java @@ -13,7 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.github.jcustenborder.kafka.connect.rabbitmq.source.data; +package com.github.themeetgroup.kafka.connect.rabbitmq.source.data; import com.google.common.collect.ImmutableMap; import com.rabbitmq.client.AMQP; @@ -44,7 +44,7 @@ public class MessageConverter implements SourceMessageConverter static final String FIELD_ENVELOPE_ROUTINGKEY = "routingKey"; static final Schema SCHEMA_ENVELOPE = SchemaBuilder.struct() - .name("com.github.jcustenborder.kafka.connect.rabbitmq.Envelope") + .name("com.github.themeetgroup.kafka.connect.rabbitmq.Envelope") .doc("Encapsulates a group of parameters used for AMQP's Basic methods. See " + "`Envelope `_") .field(FIELD_ENVELOPE_DELIVERYTAG, SchemaBuilder.int64().doc("The delivery tag included in this parameter envelope. See `Envelope.getDeliveryTag() `_").build()) @@ -65,7 +65,7 @@ static Struct envelope(Envelope envelope) { static { SchemaBuilder builder = SchemaBuilder.struct() - .name("com.github.jcustenborder.kafka.connect.rabbitmq.BasicProperties.HeaderValue") + .name("com.github.themeetgroup.kafka.connect.rabbitmq.BasicProperties.HeaderValue") .doc("Used to store the value of a header value. The `type` field stores the type of the data and the corresponding " + "field to read the data from.") .field("type", SchemaBuilder.string().doc("Used to define the type for the HeaderValue. " + @@ -105,7 +105,7 @@ static Struct envelope(Envelope envelope) { static final String FIELD_BASIC_PROPERTIES_APPID = "appId"; static final Schema SCHEMA_KEY = SchemaBuilder.struct() - .name("com.github.jcustenborder.kafka.connect.rabbitmq.MessageKey") + .name("com.github.themeetgroup.kafka.connect.rabbitmq.MessageKey") .doc("Key used for partition assignment in Kafka.") .field( FIELD_BASIC_PROPERTIES_MESSAGEID, @@ -115,7 +115,7 @@ static Struct envelope(Envelope envelope) { .build(); static final Schema SCHEMA_BASIC_PROPERTIES = SchemaBuilder.struct() - .name("com.github.jcustenborder.kafka.connect.rabbitmq.BasicProperties") + .name("com.github.themeetgroup.kafka.connect.rabbitmq.BasicProperties") .optional() .doc("Corresponds to the `BasicProperties `_") .field( @@ -272,7 +272,7 @@ static Struct basicProperties(BasicProperties basicProperties) { static final Schema SCHEMA_VALUE = SchemaBuilder.struct() - .name("com.github.jcustenborder.kafka.connect.rabbitmq.Message") + .name("com.github.themeetgroup.kafka.connect.rabbitmq.Message") .doc("Message as it is delivered to the `RabbitMQ Consumer `_ ") .field(FIELD_MESSAGE_CONSUMERTAG, SchemaBuilder.string().doc("The consumer tag associated with the consumer").build()) .field(FIELD_MESSAGE_ENVELOPE, SCHEMA_ENVELOPE) diff --git a/src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/source/data/SourceMessageConverter.java b/src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/source/data/SourceMessageConverter.java similarity index 94% rename from src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/source/data/SourceMessageConverter.java rename to src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/source/data/SourceMessageConverter.java index 8273aa9..737dba7 100644 --- a/src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/source/data/SourceMessageConverter.java +++ b/src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/source/data/SourceMessageConverter.java @@ -13,7 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.github.jcustenborder.kafka.connect.rabbitmq.source.data; +package com.github.themeetgroup.kafka.connect.rabbitmq.source.data; import com.rabbitmq.client.AMQP; import com.rabbitmq.client.Envelope; diff --git a/src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/source/data/SourceRecordBuilder.java b/src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/source/data/SourceRecordBuilder.java similarity index 94% rename from src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/source/data/SourceRecordBuilder.java rename to src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/source/data/SourceRecordBuilder.java index fb7cc84..09b2fe1 100644 --- a/src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/source/data/SourceRecordBuilder.java +++ b/src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/source/data/SourceRecordBuilder.java @@ -13,9 +13,9 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.github.jcustenborder.kafka.connect.rabbitmq.source.data; +package com.github.themeetgroup.kafka.connect.rabbitmq.source.data; -import com.github.jcustenborder.kafka.connect.rabbitmq.source.RabbitMQSourceConnectorConfig; +import com.github.themeetgroup.kafka.connect.rabbitmq.source.RabbitMQSourceConnectorConfig; import com.google.common.collect.ImmutableMap; import com.rabbitmq.client.AMQP; import com.rabbitmq.client.Envelope; diff --git a/src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/source/data/StringSourceMessageConverter.java b/src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/source/data/StringSourceMessageConverter.java similarity index 91% rename from src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/source/data/StringSourceMessageConverter.java rename to src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/source/data/StringSourceMessageConverter.java index bcf52e5..3f9a3cd 100644 --- a/src/main/java/com/github/jcustenborder/kafka/connect/rabbitmq/source/data/StringSourceMessageConverter.java +++ b/src/main/java/com/github/themeetgroup/kafka/connect/rabbitmq/source/data/StringSourceMessageConverter.java @@ -13,7 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.github.jcustenborder.kafka.connect.rabbitmq.source.data; +package com.github.themeetgroup.kafka.connect.rabbitmq.source.data; import com.rabbitmq.client.AMQP; import com.rabbitmq.client.Envelope; @@ -24,7 +24,7 @@ import java.nio.charset.Charset; import java.nio.charset.StandardCharsets; -import static com.github.jcustenborder.kafka.connect.rabbitmq.source.data.MessageConverter.basicProperties; +import static com.github.themeetgroup.kafka.connect.rabbitmq.source.data.MessageConverter.basicProperties; public class StringSourceMessageConverter implements SourceMessageConverter { diff --git a/src/test/java/com/github/jcustenborder/kafka/connect/rabbitmq/source/data/MessageConverterTest.java b/src/test/java/com/github/themeetgroup/kafka/connect/rabbitmq/source/data/MessageConverterTest.java similarity index 98% rename from src/test/java/com/github/jcustenborder/kafka/connect/rabbitmq/source/data/MessageConverterTest.java rename to src/test/java/com/github/themeetgroup/kafka/connect/rabbitmq/source/data/MessageConverterTest.java index 056ac98..9c28e7e 100644 --- a/src/test/java/com/github/jcustenborder/kafka/connect/rabbitmq/source/data/MessageConverterTest.java +++ b/src/test/java/com/github/themeetgroup/kafka/connect/rabbitmq/source/data/MessageConverterTest.java @@ -13,7 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.github.jcustenborder.kafka.connect.rabbitmq.source.data; +package com.github.themeetgroup.kafka.connect.rabbitmq.source.data; import com.google.common.collect.ImmutableMap; import com.rabbitmq.client.BasicProperties; diff --git a/src/test/java/com/github/jcustenborder/kafka/connect/rabbitmq/source/data/TransformationTest.java b/src/test/java/com/github/themeetgroup/kafka/connect/rabbitmq/source/data/TransformationTest.java similarity index 88% rename from src/test/java/com/github/jcustenborder/kafka/connect/rabbitmq/source/data/TransformationTest.java rename to src/test/java/com/github/themeetgroup/kafka/connect/rabbitmq/source/data/TransformationTest.java index 2bfd8a8..80e7143 100644 --- a/src/test/java/com/github/jcustenborder/kafka/connect/rabbitmq/source/data/TransformationTest.java +++ b/src/test/java/com/github/themeetgroup/kafka/connect/rabbitmq/source/data/TransformationTest.java @@ -1,4 +1,4 @@ -package com.github.jcustenborder.kafka.connect.rabbitmq.source.data; +package com.github.themeetgroup.kafka.connect.rabbitmq.source.data; import org.apache.kafka.connect.sink.SinkRecord; import org.apache.kafka.connect.transforms.Transformation; diff --git a/src/test/resources/logback.xml b/src/test/resources/logback.xml index ad16d57..eb3d3e6 100644 --- a/src/test/resources/logback.xml +++ b/src/test/resources/logback.xml @@ -7,5 +7,5 @@ - + \ No newline at end of file