remove 'java' part from package name (#1103)

* remove 'java' part from package name * comments and remarks pt. 1
lensesio · Apr 2, 2024 · 6003b2e · 6003b2e
1 parent 1c6e765
commit 6003b2e
Show file tree

Hide file tree

Showing 49 changed files with 144 additions and 151 deletions.
diff --git a/java-connectors/build.gradle b/java-connectors/build.gradle
@@ -6,7 +6,7 @@ plugins {
 
 allprojects {
 
-    group = "io.lenses.java.streamreactor"
+    group = "io.lenses.streamreactor"
     version = "1.0-SNAPSHOT"
 
     apply plugin: 'java'
@@ -114,7 +114,7 @@ allprojects {
         dependencies {
 //            // UNCOMMENT BELOW IF NEED CLEAN JAR
 //            exclude(dependency {
-//                it.moduleGroup != 'io.lenses.java.streamreactor'
+//                it.moduleGroup != 'io.lenses.streamreactor'
 //            })
 //        exclude(dependency('org.apache.logging.log4j:log4j-core:2.11.1'))
 //        exclude(dependency("org.apache.avro:.*"))

diff --git a/...config/AzureEventHubsConfigConstants.java → ...config/AzureEventHubsConfigConstants.java b/...config/AzureEventHubsConfigConstants.java → ...config/AzureEventHubsConfigConstants.java
@@ -1,6 +1,6 @@
-package io.lenses.java.streamreactor.connect.azure.eventhubs.config;
+package io.lenses.streamreactor.connect.azure.eventhubs.config;
 
-import io.lenses.java.streamreactor.connect.azure.eventhubs.source.AzureEventHubsSourceConnector;
+import io.lenses.streamreactor.connect.azure.eventhubs.source.AzureEventHubsSourceConnector;
 
 /**
  * Class represents Config Constants for AzureEventHubsSourceConnector Config Definition.

diff --git a/...bs/config/AzureEventHubsSourceConfig.java → ...bs/config/AzureEventHubsSourceConfig.java b/...bs/config/AzureEventHubsSourceConfig.java → ...bs/config/AzureEventHubsSourceConfig.java
@@ -1,7 +1,7 @@
-package io.lenses.java.streamreactor.connect.azure.eventhubs.config;
+package io.lenses.streamreactor.connect.azure.eventhubs.config;
 
-import io.lenses.java.streamreactor.common.config.base.BaseConfig;
-import io.lenses.java.streamreactor.common.config.base.intf.ConnectorPrefixed;
+import io.lenses.streamreactor.common.config.base.BaseConfig;
+import io.lenses.streamreactor.common.config.base.intf.ConnectorPrefixed;
 import java.util.List;
 import java.util.Map;
 import java.util.function.UnaryOperator;
@@ -88,7 +88,7 @@ public static String getPrefixedKafkaConsumerConfigKey(String kafkaConsumerConfi
 
   @Override
   public String connectorPrefix() {
-    return AzureEventHubsConfigConstants.CONNECTOR_PREFIX;
+    return connectorPrefix;
   }
 
   private static ConfigDef getKafkaConsumerConfigToExpose() {

diff --git a/...zure/eventhubs/config/SourceDataType.java → ...zure/eventhubs/config/SourceDataType.java b/...zure/eventhubs/config/SourceDataType.java → ...zure/eventhubs/config/SourceDataType.java
@@ -1,4 +1,4 @@
-package io.lenses.java.streamreactor.connect.azure.eventhubs.config;
+package io.lenses.streamreactor.connect.azure.eventhubs.config;
 
 import java.util.Arrays;
 import java.util.Map;

diff --git a/...eventhubs/mapping/SourceRecordMapper.java → ...eventhubs/mapping/SourceRecordMapper.java b/...eventhubs/mapping/SourceRecordMapper.java → ...eventhubs/mapping/SourceRecordMapper.java
@@ -1,4 +1,4 @@
-package io.lenses.java.streamreactor.connect.azure.eventhubs.mapping;
+package io.lenses.streamreactor.connect.azure.eventhubs.mapping;
 
 import java.util.Map;
 import org.apache.kafka.clients.consumer.ConsumerRecord;

diff --git a/...urce/AzureConsumerRebalancerListener.java → ...urce/AzureConsumerRebalancerListener.java b/...urce/AzureConsumerRebalancerListener.java → ...urce/AzureConsumerRebalancerListener.java
@@ -1,7 +1,7 @@
-package io.lenses.java.streamreactor.connect.azure.eventhubs.source;
+package io.lenses.streamreactor.connect.azure.eventhubs.source;
 
-import io.lenses.java.streamreactor.connect.azure.eventhubs.source.TopicPartitionOffsetProvider.AzureOffsetMarker;
-import io.lenses.java.streamreactor.connect.azure.eventhubs.source.TopicPartitionOffsetProvider.AzureTopicPartitionKey;
+import io.lenses.streamreactor.connect.azure.eventhubs.source.TopicPartitionOffsetProvider.AzureOffsetMarker;
+import io.lenses.streamreactor.connect.azure.eventhubs.source.TopicPartitionOffsetProvider.AzureTopicPartitionKey;
 import java.util.ArrayList;
 import java.util.Collection;
 import java.util.List;

diff --git a/...source/AzureEventHubsSourceConnector.java → ...source/AzureEventHubsSourceConnector.java b/...source/AzureEventHubsSourceConnector.java → ...source/AzureEventHubsSourceConnector.java
@@ -1,11 +1,11 @@
-package io.lenses.java.streamreactor.connect.azure.eventhubs.source;
+package io.lenses.streamreactor.connect.azure.eventhubs.source;
 
-import static io.lenses.java.streamreactor.common.util.AsciiArtPrinter.printAsciiHeader;
+import static io.lenses.streamreactor.common.util.AsciiArtPrinter.printAsciiHeader;
 
-import io.lenses.java.streamreactor.common.util.JarManifest;
-import io.lenses.java.streamreactor.connect.azure.eventhubs.config.AzureEventHubsSourceConfig;
-import io.lenses.java.streamreactor.connect.azure.eventhubs.config.AzureEventHubsConfigConstants;
-import io.lenses.java.streamreactor.connect.azure.eventhubs.util.KcqlConfigPort;
+import io.lenses.streamreactor.common.util.JarManifest;
+import io.lenses.streamreactor.connect.azure.eventhubs.config.AzureEventHubsSourceConfig;
+import io.lenses.streamreactor.connect.azure.eventhubs.config.AzureEventHubsConfigConstants;
+import io.lenses.streamreactor.connect.azure.eventhubs.util.KcqlConfigPort;
 import io.lenses.kcql.Kcql;
 import java.util.ArrayList;
 import java.util.List;
@@ -59,6 +59,7 @@ public ExactlyOnceSupport exactlyOnceSupport(Map<String, String> connectorConfig
 
   @Override
   public void stop() {
+    // connector-specific implementation not needed
   }
 
   @Override

diff --git a/...hubs/source/AzureEventHubsSourceTask.java → ...hubs/source/AzureEventHubsSourceTask.java b/...hubs/source/AzureEventHubsSourceTask.java → ...hubs/source/AzureEventHubsSourceTask.java
@@ -1,11 +1,11 @@
-package io.lenses.java.streamreactor.connect.azure.eventhubs.source;
+package io.lenses.streamreactor.connect.azure.eventhubs.source;
 
 import static java.util.Optional.ofNullable;
 
-import io.lenses.java.streamreactor.common.util.JarManifest;
-import io.lenses.java.streamreactor.connect.azure.eventhubs.config.AzureEventHubsConfigConstants;
-import io.lenses.java.streamreactor.connect.azure.eventhubs.config.AzureEventHubsSourceConfig;
-import io.lenses.java.streamreactor.connect.azure.eventhubs.util.KcqlConfigPort;
+import io.lenses.streamreactor.common.util.JarManifest;
+import io.lenses.streamreactor.connect.azure.eventhubs.config.AzureEventHubsConfigConstants;
+import io.lenses.streamreactor.connect.azure.eventhubs.config.AzureEventHubsSourceConfig;
+import io.lenses.streamreactor.connect.azure.eventhubs.util.KcqlConfigPort;
 import io.lenses.kcql.Kcql;
 import java.time.Duration;
 import java.time.temporal.ChronoUnit;

diff --git a/...enthubs/source/BlockingQueueProducer.java → ...enthubs/source/BlockingQueueProducer.java b/...enthubs/source/BlockingQueueProducer.java → ...enthubs/source/BlockingQueueProducer.java
@@ -1,4 +1,4 @@
-package io.lenses.java.streamreactor.connect.azure.eventhubs.source;
+package io.lenses.streamreactor.connect.azure.eventhubs.source;
 
 import java.time.Duration;
 

diff --git a/...source/BlockingQueueProducerProvider.java → ...source/BlockingQueueProducerProvider.java b/...source/BlockingQueueProducerProvider.java → ...source/BlockingQueueProducerProvider.java
@@ -1,11 +1,9 @@
-package io.lenses.java.streamreactor.connect.azure.eventhubs.source;
+package io.lenses.streamreactor.connect.azure.eventhubs.source;
 
-import static io.lenses.java.streamreactor.connect.azure.eventhubs.config.AzureEventHubsSourceConfig.getPrefixedKafkaConsumerConfigKey;
-
-import io.lenses.java.streamreactor.connect.azure.eventhubs.config.AzureEventHubsConfigConstants;
-import io.lenses.java.streamreactor.connect.azure.eventhubs.config.AzureEventHubsSourceConfig;
-import io.lenses.java.streamreactor.connect.azure.eventhubs.config.SourceDataType.KeyValueTypes;
-import io.lenses.java.streamreactor.connect.azure.eventhubs.util.KcqlConfigPort;
+import io.lenses.streamreactor.connect.azure.eventhubs.config.AzureEventHubsConfigConstants;
+import io.lenses.streamreactor.connect.azure.eventhubs.config.AzureEventHubsSourceConfig;
+import io.lenses.streamreactor.connect.azure.eventhubs.config.SourceDataType.KeyValueTypes;
+import io.lenses.streamreactor.connect.azure.eventhubs.util.KcqlConfigPort;
 import io.lenses.kcql.Kcql;
 import java.util.Map;
 import java.util.UUID;
@@ -54,7 +52,7 @@ public KafkaByteBlockingQueuedProducer createProducer(
 
     consumerProperties.put(ConsumerConfig.CLIENT_ID_CONFIG, clientId);
     consumerProperties.put(ConsumerConfig.GROUP_ID_CONFIG, azureEventHubsSourceConfig.getString(
-            getPrefixedKafkaConsumerConfigKey(ConsumerConfig.GROUP_ID_CONFIG)));
+            AzureEventHubsSourceConfig.getPrefixedKafkaConsumerConfigKey(ConsumerConfig.GROUP_ID_CONFIG)));
     consumerProperties.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG,
             keyValueTypes.getKeyType().getDeserializerClass());
     consumerProperties.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG,

diff --git a/...rce/EventHubsKafkaConsumerController.java → ...rce/EventHubsKafkaConsumerController.java b/...rce/EventHubsKafkaConsumerController.java → ...rce/EventHubsKafkaConsumerController.java
@@ -1,9 +1,9 @@
-package io.lenses.java.streamreactor.connect.azure.eventhubs.source;
+package io.lenses.streamreactor.connect.azure.eventhubs.source;
 
-import static io.lenses.java.streamreactor.connect.azure.eventhubs.mapping.SourceRecordMapper.mapSourceRecordIncludingHeaders;
+import static io.lenses.streamreactor.connect.azure.eventhubs.mapping.SourceRecordMapper.mapSourceRecordIncludingHeaders;
 
-import io.lenses.java.streamreactor.connect.azure.eventhubs.source.TopicPartitionOffsetProvider.AzureOffsetMarker;
-import io.lenses.java.streamreactor.connect.azure.eventhubs.source.TopicPartitionOffsetProvider.AzureTopicPartitionKey;
+import io.lenses.streamreactor.connect.azure.eventhubs.source.TopicPartitionOffsetProvider.AzureOffsetMarker;
+import io.lenses.streamreactor.connect.azure.eventhubs.source.TopicPartitionOffsetProvider.AzureTopicPartitionKey;
 import java.time.Duration;
 import java.time.temporal.ChronoUnit;
 import java.util.ArrayList;

diff --git a/...urce/KafkaByteBlockingQueuedProducer.java → ...urce/KafkaByteBlockingQueuedProducer.java b/...urce/KafkaByteBlockingQueuedProducer.java → ...urce/KafkaByteBlockingQueuedProducer.java
@@ -1,6 +1,6 @@
-package io.lenses.java.streamreactor.connect.azure.eventhubs.source;
+package io.lenses.streamreactor.connect.azure.eventhubs.source;
 
-import io.lenses.java.streamreactor.connect.azure.eventhubs.config.SourceDataType.KeyValueTypes;
+import io.lenses.streamreactor.connect.azure.eventhubs.config.SourceDataType.KeyValueTypes;
 import java.time.Duration;
 import java.time.temporal.ChronoUnit;
 import java.util.Collections;

diff --git a/...re/eventhubs/source/ProducerProvider.java → ...re/eventhubs/source/ProducerProvider.java b/...re/eventhubs/source/ProducerProvider.java → ...re/eventhubs/source/ProducerProvider.java
@@ -1,6 +1,6 @@
-package io.lenses.java.streamreactor.connect.azure.eventhubs.source;
+package io.lenses.streamreactor.connect.azure.eventhubs.source;
 
-import io.lenses.java.streamreactor.connect.azure.eventhubs.config.AzureEventHubsSourceConfig;
+import io.lenses.streamreactor.connect.azure.eventhubs.config.AzureEventHubsSourceConfig;
 import java.util.concurrent.BlockingQueue;
 import org.apache.kafka.clients.consumer.ConsumerRecords;
 

diff --git a/.../source/TopicPartitionOffsetProvider.java → .../source/TopicPartitionOffsetProvider.java b/.../source/TopicPartitionOffsetProvider.java → .../source/TopicPartitionOffsetProvider.java
@@ -1,4 +1,4 @@
-package io.lenses.java.streamreactor.connect.azure.eventhubs.source;
+package io.lenses.streamreactor.connect.azure.eventhubs.source;
 
 import java.util.HashMap;
 import java.util.Map;

diff --git a/.../azure/eventhubs/util/KcqlConfigPort.java → .../azure/eventhubs/util/KcqlConfigPort.java b/.../azure/eventhubs/util/KcqlConfigPort.java → .../azure/eventhubs/util/KcqlConfigPort.java
@@ -1,4 +1,4 @@
-package io.lenses.java.streamreactor.connect.azure.eventhubs.util;
+package io.lenses.streamreactor.connect.azure.eventhubs.util;
 
 import io.lenses.kcql.Kcql;
 

diff --git a/...hubs/src/main/resources/META-INF/services/org.apache.kafka.connect.source.SourceConnector b/...hubs/src/main/resources/META-INF/services/org.apache.kafka.connect.source.SourceConnector
@@ -1 +1 @@
-io.lenses.java.streamreactor.connect.azure.eventhubs.source.AzureEventHubsSourceConnector
+io.lenses.streamreactor.connect.azure.eventhubs.source.AzureEventHubsSourceConnector
diff --git a/.../eventhubs/config/SourceDataTypeTest.java → .../eventhubs/config/SourceDataTypeTest.java b/.../eventhubs/config/SourceDataTypeTest.java → .../eventhubs/config/SourceDataTypeTest.java
@@ -1,4 +1,4 @@
-package io.lenses.java.streamreactor.connect.azure.eventhubs.config;
+package io.lenses.streamreactor.connect.azure.eventhubs.config;
 
 import static org.apache.kafka.connect.data.Schema.OPTIONAL_BYTES_SCHEMA;
 import static org.junit.jupiter.api.Assertions.assertEquals;

diff --git a/...thubs/mapping/SourceRecordMapperTest.java → ...thubs/mapping/SourceRecordMapperTest.java b/...thubs/mapping/SourceRecordMapperTest.java → ...thubs/mapping/SourceRecordMapperTest.java
@@ -1,4 +1,4 @@
-package io.lenses.java.streamreactor.connect.azure.eventhubs.mapping;
+package io.lenses.streamreactor.connect.azure.eventhubs.mapping;
 
 import static java.util.Collections.singletonList;
 import static org.junit.jupiter.api.Assertions.assertEquals;
@@ -8,8 +8,8 @@
 import static org.mockito.Mockito.verify;
 import static org.mockito.Mockito.when;
 
-import io.lenses.java.streamreactor.connect.azure.eventhubs.source.TopicPartitionOffsetProvider.AzureOffsetMarker;
-import io.lenses.java.streamreactor.connect.azure.eventhubs.source.TopicPartitionOffsetProvider.AzureTopicPartitionKey;
+import io.lenses.streamreactor.connect.azure.eventhubs.source.TopicPartitionOffsetProvider.AzureOffsetMarker;
+import io.lenses.streamreactor.connect.azure.eventhubs.source.TopicPartitionOffsetProvider.AzureTopicPartitionKey;
 import java.util.Iterator;
 import org.apache.kafka.clients.consumer.ConsumerRecord;
 import org.apache.kafka.common.header.Header;

diff --git a/.../AzureConsumerRebalancerListenerTest.java → .../AzureConsumerRebalancerListenerTest.java b/.../AzureConsumerRebalancerListenerTest.java → .../AzureConsumerRebalancerListenerTest.java
@@ -1,4 +1,4 @@
-package io.lenses.java.streamreactor.connect.azure.eventhubs.source;
+package io.lenses.streamreactor.connect.azure.eventhubs.source;
 
 import static org.mockito.ArgumentMatchers.any;
 import static org.mockito.ArgumentMatchers.anyList;
@@ -7,8 +7,8 @@
 import static org.mockito.Mockito.verify;
 import static org.mockito.Mockito.when;
 
-import io.lenses.java.streamreactor.connect.azure.eventhubs.source.TopicPartitionOffsetProvider.AzureOffsetMarker;
-import io.lenses.java.streamreactor.connect.azure.eventhubs.source.TopicPartitionOffsetProvider.AzureTopicPartitionKey;
+import io.lenses.streamreactor.connect.azure.eventhubs.source.TopicPartitionOffsetProvider.AzureOffsetMarker;
+import io.lenses.streamreactor.connect.azure.eventhubs.source.TopicPartitionOffsetProvider.AzureTopicPartitionKey;
 import java.util.Collections;
 import java.util.Optional;
 import org.apache.kafka.clients.consumer.Consumer;

diff --git a/.../source/AzureEventHubsSourceTaskTest.java → .../source/AzureEventHubsSourceTaskTest.java b/.../source/AzureEventHubsSourceTaskTest.java → .../source/AzureEventHubsSourceTaskTest.java
@@ -1,4 +1,4 @@
-package io.lenses.java.streamreactor.connect.azure.eventhubs.source;
+package io.lenses.streamreactor.connect.azure.eventhubs.source;
 
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertIterableEquals;
@@ -13,9 +13,9 @@
 
 import ch.qos.logback.classic.spi.ILoggingEvent;
 import ch.qos.logback.core.read.ListAppender;
-import io.lenses.java.streamreactor.common.util.JarManifest;
-import io.lenses.java.streamreactor.connect.azure.eventhubs.config.AzureEventHubsSourceConfig;
-import io.lenses.java.streamreactor.connect.azure.eventhubs.config.AzureEventHubsConfigConstants;
+import io.lenses.streamreactor.common.util.JarManifest;
+import io.lenses.streamreactor.connect.azure.eventhubs.config.AzureEventHubsConfigConstants;
+import io.lenses.streamreactor.connect.azure.eventhubs.config.AzureEventHubsSourceConfig;
 import java.time.Duration;
 import java.util.Collections;
 import java.util.List;

diff --git a/...ce/BlockingQueueProducerProviderTest.java → ...ce/BlockingQueueProducerProviderTest.java b/...ce/BlockingQueueProducerProviderTest.java → ...ce/BlockingQueueProducerProviderTest.java
@@ -1,6 +1,5 @@
-package io.lenses.java.streamreactor.connect.azure.eventhubs.source;
+package io.lenses.streamreactor.connect.azure.eventhubs.source;
 
-import static io.lenses.java.streamreactor.connect.azure.eventhubs.config.AzureEventHubsSourceConfig.getPrefixedKafkaConsumerConfigKey;
 import static org.apache.kafka.clients.consumer.ConsumerConfig.GROUP_ID_CONFIG;
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertNotNull;
@@ -12,8 +11,8 @@
 
 import ch.qos.logback.classic.spi.ILoggingEvent;
 import ch.qos.logback.core.read.ListAppender;
-import io.lenses.java.streamreactor.connect.azure.eventhubs.config.AzureEventHubsSourceConfig;
-import io.lenses.java.streamreactor.connect.azure.eventhubs.config.AzureEventHubsConfigConstants;
+import io.lenses.streamreactor.connect.azure.eventhubs.config.AzureEventHubsSourceConfig;
+import io.lenses.streamreactor.connect.azure.eventhubs.config.AzureEventHubsConfigConstants;
 import java.util.concurrent.ArrayBlockingQueue;
 import org.apache.kafka.clients.consumer.KafkaConsumer;
 import org.apache.kafka.common.config.ConfigException;
@@ -86,7 +85,7 @@ void whenConstructorInvokedWithParameters_ThenMockKafkaConsumerShouldBeCreatedAn
 
     //then
     verify(azureConfigMock).getString(AzureEventHubsConfigConstants.CONNECTOR_NAME);
-    verify(azureConfigMock).getString(getPrefixedKafkaConsumerConfigKey(GROUP_ID_CONFIG));
+    verify(azureConfigMock).getString(AzureEventHubsSourceConfig.getPrefixedKafkaConsumerConfigKey(GROUP_ID_CONFIG));
     assertNotNull(consumer);
     assertEquals(1, logWatcher.list.size());
     assertTrue(logWatcher.list.get(0).getFormattedMessage().startsWith("Attempting to create Client with Id"));

diff --git a/...EventHubsKafkaConsumerControllerTest.java → ...EventHubsKafkaConsumerControllerTest.java b/...EventHubsKafkaConsumerControllerTest.java → ...EventHubsKafkaConsumerControllerTest.java
@@ -1,4 +1,4 @@
-package io.lenses.java.streamreactor.connect.azure.eventhubs.source;
+package io.lenses.streamreactor.connect.azure.eventhubs.source;
 
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertNotNull;
@@ -7,8 +7,8 @@
 import static org.mockito.Mockito.verify;
 import static org.mockito.Mockito.when;
 
-import io.lenses.java.streamreactor.connect.azure.eventhubs.config.SourceDataType;
-import io.lenses.java.streamreactor.connect.azure.eventhubs.config.SourceDataType.KeyValueTypes;
+import io.lenses.streamreactor.connect.azure.eventhubs.config.SourceDataType;
+import io.lenses.streamreactor.connect.azure.eventhubs.config.SourceDataType.KeyValueTypes;
 import java.time.Duration;
 import java.time.temporal.ChronoUnit;
 import java.util.Collections;

diff --git a/.../KafkaByteBlockingQueuedProducerTest.java → .../KafkaByteBlockingQueuedProducerTest.java b/.../KafkaByteBlockingQueuedProducerTest.java → .../KafkaByteBlockingQueuedProducerTest.java
@@ -1,10 +1,10 @@
-package io.lenses.java.streamreactor.connect.azure.eventhubs.source;
+package io.lenses.streamreactor.connect.azure.eventhubs.source;
 
 import static org.mockito.ArgumentMatchers.eq;
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.verify;
 
-import io.lenses.java.streamreactor.connect.azure.eventhubs.config.SourceDataType.KeyValueTypes;
+import io.lenses.streamreactor.connect.azure.eventhubs.config.SourceDataType.KeyValueTypes;
 import java.time.Duration;
 import java.time.temporal.ChronoUnit;
 import java.util.concurrent.BlockingQueue;

diff --git a/...rce/TopicPartitionOffsetProviderTest.java → ...rce/TopicPartitionOffsetProviderTest.java b/...rce/TopicPartitionOffsetProviderTest.java → ...rce/TopicPartitionOffsetProviderTest.java
@@ -1,4 +1,4 @@
-package io.lenses.java.streamreactor.connect.azure.eventhubs.source;
+package io.lenses.streamreactor.connect.azure.eventhubs.source;
 
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertTrue;
@@ -7,8 +7,8 @@
 import static org.mockito.Mockito.verify;
 import static org.mockito.Mockito.when;
 
-import io.lenses.java.streamreactor.connect.azure.eventhubs.source.TopicPartitionOffsetProvider.AzureOffsetMarker;
-import io.lenses.java.streamreactor.connect.azure.eventhubs.source.TopicPartitionOffsetProvider.AzureTopicPartitionKey;
+import io.lenses.streamreactor.connect.azure.eventhubs.source.TopicPartitionOffsetProvider.AzureOffsetMarker;
+import io.lenses.streamreactor.connect.azure.eventhubs.source.TopicPartitionOffsetProvider.AzureTopicPartitionKey;
 import java.util.HashMap;
 import java.util.Map;
 import java.util.Optional;

diff --git a/...re/eventhubs/util/KcqlConfigPortTest.java → ...re/eventhubs/util/KcqlConfigPortTest.java b/...re/eventhubs/util/KcqlConfigPortTest.java → ...re/eventhubs/util/KcqlConfigPortTest.java
@@ -1,4 +1,4 @@
-package io.lenses.java.streamreactor.connect.azure.eventhubs.util;
+package io.lenses.streamreactor.connect.azure.eventhubs.util;
 
 import static org.junit.jupiter.api.Assertions.*;
 

diff --git a/.../src/main/java/io/lenses/java/streamreactor/common/config/base/intf/DatabaseSettings.java b/.../src/main/java/io/lenses/java/streamreactor/common/config/base/intf/DatabaseSettings.java
diff --git a/...c/main/java/io/lenses/java/streamreactor/common/config/base/intf/ErrorPolicySettings.java b/...c/main/java/io/lenses/java/streamreactor/common/config/base/intf/ErrorPolicySettings.java
diff --git a/...main/java/io/lenses/java/streamreactor/common/config/base/intf/NumberRetriesSettings.java b/...main/java/io/lenses/java/streamreactor/common/config/base/intf/NumberRetriesSettings.java
diff --git a/...mmon/src/main/java/io/lenses/java/streamreactor/common/config/base/intf/UserSettings.java b/...mmon/src/main/java/io/lenses/java/streamreactor/common/config/base/intf/UserSettings.java
Original file line number	Diff line number	Diff line change
		@@ -1 +1 @@
		io.lenses.java.streamreactor.connect.azure.eventhubs.source.AzureEventHubsSourceConnector
		io.lenses.streamreactor.connect.azure.eventhubs.source.AzureEventHubsSourceConnector