Rename package name to themeetgroup

Change-Id: Id6214a0add10152bd5e67d27e2fcbb6f4e9e204b
cobolbaby · Nov 19, 2020 · 1cbce8d · 1cbce8d
1 parent 3e3856a
commit 1cbce8d
Show file tree

Hide file tree

Showing 19 changed files with 38 additions and 42 deletions.
diff --git 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) <https://www.rabbitmq.com/releases/rabbitmq-java-client/current-javadoc/com/rabbitmq/client/ConnectionFactory.html#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
@@ -100,11 +100,9 @@
                             <goal>kafka-connect</goal>
                         </goals>
                         <configuration>
-                            <ownerUsername>jcustenborder</ownerUsername>
-                            <confluentControlCenterIntegration>true</confluentControlCenterIntegration>
-                            <documentationUrl>https://jcustenborder.github.io/kafka-connect-documentation/</documentationUrl>
-                            <ownerName>Jeremy Custenborder</ownerName>
-                            <dockerNamespace>jcustenborder</dockerNamespace>
+                            <ownerUsername>themeetgroup</ownerUsername>
+                            <ownerName>The Meet Group</ownerName>
+                            <dockerNamespace>themeetgroup</dockerNamespace>
                             <dockerName>kafka-connect-docker</dockerName>
                             <componentTypes>
                                 <componentType>sink</componentType>
@@ -116,8 +114,6 @@
                                 <tag>Messaging</tag>
                             </tags>
                             <title>Kafka Connect RabbitMQ</title>
-                            <supportUrl>${project.issueManagement.url}</supportUrl>
-                            <supportSummary>Support provided through community involvement.</supportSummary>
                         </configuration>
                     </execution>
                 </executions>

diff --git a/...bbitmq/CommonRabbitMQConnectorConfig.java → ...bbitmq/CommonRabbitMQConnectorConfig.java b/...bbitmq/CommonRabbitMQConnectorConfig.java → ...bbitmq/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/.../rabbitmq/sink/RabbitMQSinkConnector.java → .../rabbitmq/sink/RabbitMQSinkConnector.java b/.../rabbitmq/sink/RabbitMQSinkConnector.java → .../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/...tmq/sink/RabbitMQSinkConnectorConfig.java → ...tmq/sink/RabbitMQSinkConnectorConfig.java b/...tmq/sink/RabbitMQSinkConnectorConfig.java → ...tmq/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/...bbitmq/sink/RabbitMQSinkHeaderParser.java → ...bbitmq/sink/RabbitMQSinkHeaderParser.java b/...bbitmq/sink/RabbitMQSinkHeaderParser.java → ...bbitmq/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/...nnect/rabbitmq/sink/RabbitMQSinkTask.java → ...nnect/rabbitmq/sink/RabbitMQSinkTask.java b/...nnect/rabbitmq/sink/RabbitMQSinkTask.java → ...nnect/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/...nect/rabbitmq/source/ConnectConsumer.java → ...nect/rabbitmq/source/ConnectConsumer.java b/...nect/rabbitmq/source/ConnectConsumer.java → ...nect/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/...bitmq/source/RabbitMQSourceConnector.java → ...bitmq/source/RabbitMQSourceConnector.java b/...bitmq/source/RabbitMQSourceConnector.java → ...bitmq/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/...source/RabbitMQSourceConnectorConfig.java → ...source/RabbitMQSourceConnectorConfig.java b/...source/RabbitMQSourceConnectorConfig.java → ...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<String> queues;

diff --git a/...t/rabbitmq/source/RabbitMQSourceTask.java → ...t/rabbitmq/source/RabbitMQSourceTask.java b/...t/rabbitmq/source/RabbitMQSourceTask.java → ...t/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/...rce/data/BytesSourceMessageConverter.java → ...rce/data/BytesSourceMessageConverter.java b/...rce/data/BytesSourceMessageConverter.java → ...rce/data/BytesSourceMessageConverter.java
@@ -13,15 +13,15 @@
  * 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;
 import org.apache.kafka.connect.data.Schema;
 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<String, byte[]> {
 

diff --git a/...abbitmq/source/data/MessageConverter.java → ...abbitmq/source/data/MessageConverter.java b/...abbitmq/source/data/MessageConverter.java → ...abbitmq/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<Struct, Struct>
   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 <https://www.rabbitmq.com/releases/rabbitmq-java-client/current-javadoc/com/rabbitmq/client/Envelope.html>`_")
       .field(FIELD_ENVELOPE_DELIVERYTAG, SchemaBuilder.int64().doc("The delivery tag included in this parameter envelope. See `Envelope.getDeliveryTag() <https://www.rabbitmq.com/releases/rabbitmq-java-client/current-javadoc/com/rabbitmq/client/Envelope.html#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 <https://www.rabbitmq.com/releases/rabbitmq-java-client/current-javadoc/com/rabbitmq/client/BasicProperties.html>`_")
       .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 <https://www.rabbitmq.com/releases/rabbitmq-java-client/current-javadoc/com/rabbitmq/client/Consumer.html#handleDelivery-java.lang.String-com.rabbitmq.client.Envelope-com.rabbitmq.client.AMQP.BasicProperties-byte:A->`_ ")
       .field(FIELD_MESSAGE_CONSUMERTAG, SchemaBuilder.string().doc("The consumer tag associated with the consumer").build())
       .field(FIELD_MESSAGE_ENVELOPE, SCHEMA_ENVELOPE)

diff --git a/...q/source/data/SourceMessageConverter.java → ...q/source/data/SourceMessageConverter.java b/...q/source/data/SourceMessageConverter.java → ...q/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/...itmq/source/data/SourceRecordBuilder.java → ...itmq/source/data/SourceRecordBuilder.java b/...itmq/source/data/SourceRecordBuilder.java → ...itmq/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/...ce/data/StringSourceMessageConverter.java → ...ce/data/StringSourceMessageConverter.java b/...ce/data/StringSourceMessageConverter.java → ...ce/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/...tmq/source/data/MessageConverterTest.java → ...tmq/source/data/MessageConverterTest.java b/...tmq/source/data/MessageConverterTest.java → ...tmq/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/...bitmq/source/data/TransformationTest.java → ...bitmq/source/data/TransformationTest.java b/...bitmq/source/data/TransformationTest.java → ...bitmq/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
@@ -7,5 +7,5 @@
     <root level="INFO">
         <appender-ref ref="STDOUT" />
     </root>
-    <logger name="com.github.jcustenborder.kafka.connect.rabbitmq" level="TRACE" />
+    <logger name="com.github.themeetgroup.kafka.connect.rabbitmq" level="TRACE" />
 </configuration>