Checkpoint

buildSrc/build.gradle

@@ -0,0 +1,11 @@
+plugins {
+    id 'groovy-gradle-plugin'
+}
+
+repositories {
+    gradlePluginPortal()
+}
+
+dependencies {
+    implementation "com.diffplug.spotless:spotless-plugin-gradle:6.25.0"
+}

build.gradle → buildSrc/src/main/groovy/lightstreamer-kafka-connector.gradle

@@ -1,11 +1,11 @@
 plugins {
     id 'java-library'
-    id 'eclipse'
-    id 'distribution'
-    id "com.github.davidmc24.gradle.plugin.avro" version "1.9.1"
-    id("com.diffplug.spotless") version "6.25.0"
+    id 'java-library-distribution'
+    id("com.diffplug.spotless")
 }
 
+group = 'com.lightstreamer.kafka_connector'
+
 spotless {
     format 'misc', {
         target '*.gradle'
@@ -47,8 +47,6 @@ spotless {
     }
 }
 
-version = '0.1.0'
-
 repositories {
     mavenCentral()
     maven {
@@ -61,14 +59,6 @@ dependencies {
     testImplementation('org.junit.jupiter:junit-jupiter')
     testImplementation "com.google.truth:truth:1.2.0"
     testImplementation "com.google.truth.extensions:truth-java8-extension:1.2.0"
-
-    implementation group: 'com.lightstreamer', name: 'ls-adapter-inprocess', version: '8.0.0'
-    implementation group: 'org.slf4j', name: 'slf4j-reload4j', 'version': '2.0.10'
-
-    implementation group:'org.apache.kafka', name:'kafka-clients', version:'7.5.3-ccs'
-    implementation group:'io.confluent', name: 'kafka-avro-serializer', version:'7.5.3'
-    implementation group:'io.confluent', name: 'kafka-json-serializer', version:'7.5.3'
-    implementation group:'io.confluent', name: 'kafka-json-schema-serializer', version:'7.5.3'
 }
 
 java {
@@ -79,58 +69,4 @@ java {
 
 tasks.named('test') {
     useJUnitPlatform()
-}
-
-task deployAdapters(type: Copy) {
-    dependsOn 'cleanDeploy'
-
-    into "deploy"
-
-    from (jar) {
-        into "connector/lib"
-    }
-
-    from (configurations.runtimeClasspath) {
-        into "connector/lib"
-        exclude "ls-adapter-inprocess*"
-        exclude "jsr305*"
-    }
-
-    from ("examples/quickstart") {
-        into "connector"
-    }
-}
-
-task deploy(type: Copy) {
-    dependsOn 'deployAdapters'
-    into "deploy/conf"
-    from ("examples/conf")
-}
-
-task cleanDeploy(type: Delete) {
-    delete "deploy"
-}
-
-sourceSets.main.java.srcDirs += ['src/clients/java']
-
-distributions {
-    connector {
-        distributionBaseName =  rootProject.name
-
-        contents {
-            from(jar) {
-                into "lib"
-            }
-
-            from (configurations.runtimeClasspath) {
-                into "lib"
-                exclude "ls-adapter-inprocess*"
-                exclude "jsr305*"
-            }
-        }
-    }
-}
-
-task distribuite {
-    dependsOn connectorDistZip
-}
+}

connector/.classpath

@@ -0,0 +1,32 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<classpath>
+	<classpathentry kind="src" output="bin/test" path="src/test/resources">
+		<attributes>
+			<attribute name="gradle_scope" value="test"/>
+			<attribute name="gradle_used_by_scope" value="test"/>
+			<attribute name="test" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="src" output="bin/test" path="src/test/java">
+		<attributes>
+			<attribute name="gradle_scope" value="test"/>
+			<attribute name="gradle_used_by_scope" value="test"/>
+			<attribute name="test" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="src" output="bin/main" path="src/main/resources">
+		<attributes>
+			<attribute name="gradle_scope" value="main"/>
+			<attribute name="gradle_used_by_scope" value="main,test"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="src" output="bin/main" path="src/main/java">
+		<attributes>
+			<attribute name="gradle_scope" value="main"/>
+			<attribute name="gradle_used_by_scope" value="main,test"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/JavaSE-17/"/>
+	<classpathentry kind="con" path="org.eclipse.buildship.core.gradleclasspathcontainer"/>
+	<classpathentry kind="output" path="bin/default"/>
+</classpath>

connector/.project

@@ -0,0 +1,34 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<projectDescription>
+	<name>connector</name>
+	<comment>Project connector created by Buildship.</comment>
+	<projects>
+	</projects>
+	<buildSpec>
+		<buildCommand>
+			<name>org.eclipse.jdt.core.javabuilder</name>
+			<arguments>
+			</arguments>
+		</buildCommand>
+		<buildCommand>
+			<name>org.eclipse.buildship.core.gradleprojectbuilder</name>
+			<arguments>
+			</arguments>
+		</buildCommand>
+	</buildSpec>
+	<natures>
+		<nature>org.eclipse.jdt.core.javanature</nature>
+		<nature>org.eclipse.buildship.core.gradleprojectnature</nature>
+	</natures>
+	<filteredResources>
+		<filter>
+			<id>1708629776379</id>
+			<name></name>
+			<type>30</type>
+			<matcher>
+				<id>org.eclipse.core.resources.regexFilterMatcher</id>
+				<arguments>node_modules|\.git|__CREATED_BY_JAVA_LANGUAGE_SERVER__</arguments>
+			</matcher>
+		</filter>
+	</filteredResources>
+</projectDescription>

connector/build.gradle

@@ -0,0 +1,67 @@
+plugins {
+    id 'lightstreamer-kafka-connector'
+    id "com.github.davidmc24.gradle.plugin.avro" version "1.9.1"
+}
+
+dependencies {
+    implementation group: 'com.lightstreamer', name: 'ls-adapter-inprocess', version: '8.0.0'
+    implementation group: 'org.slf4j', name: 'slf4j-reload4j', 'version': '2.0.10'
+    implementation group: 'org.apache.kafka', name:'kafka-clients', version:'7.5.3-ccs'
+    implementation group: 'io.confluent', name: 'kafka-avro-serializer', version:'7.5.3'
+    implementation group: 'io.confluent', name: 'kafka-json-serializer', version:'7.5.3'
+    implementation group: 'io.confluent', name: 'kafka-json-schema-serializer', version:'7.5.3'
+}
+
+task deployAdapters(type: Copy) {
+    dependsOn 'cleanDeploy'
+
+    into "deploy"
+
+    from (jar) {
+        into "connector/lib"
+    }
+
+    from (configurations.runtimeClasspath) {
+        into "connector/lib"
+        exclude "ls-adapter-inprocess*"
+        exclude "jsr305*"
+    }
+
+    from ("examples/quickstart") {
+        into "connector"
+    }
+}
+
+task deploy(type: Copy) {
+    dependsOn 'deployAdapters'
+    into "deploy/conf"
+    from ("examples/conf")
+}
+
+task cleanDeploy(type: Delete) {
+    delete "deploy"
+}
+
+sourceSets.main.java.srcDirs += ['src/clients/java']
+
+distributions {
+    connector {
+        distributionBaseName =  rootProject.name
+
+        contents {
+            from(jar) {
+                into "lib"
+            }
+
+            from (configurations.runtimeClasspath) {
+                into "lib"
+                exclude "ls-adapter-inprocess*"
+                exclude "jsr305*"
+            }
+        }
+    }
+}
+
+task distribuite {
+    dependsOn connectorDistZip
+}

src/connector/dist/adapters.xml → connector/src/connector/dist/adapters.xml

@@ -125,7 +125,7 @@
 
         <param name="group.id">test</param>
 
-        <param name="enable">true</param>
+        <param name="enable">disable</param>
 
         <!-- TOPIC MAPPING SECTION -->
 

src/main/java/com/lightstreamer/kafka_connector/adapters/ConnectorMetadataAdapter.java → connector/src/main/java/com/lightstreamer/kafka_connector/adapters/ConnectorMetadataAdapter.java

@@ -29,5 +29,6 @@ public void onUnsubscription(String user, String sessionID, TableInfo[] tables)
             throws CreditsException, NotificationException {}
 
     @Override
-    public void onUnsubscription(String sessionID, TableInfo[] tables) throws NotificationException {}
+    public void onUnsubscription(String sessionID, TableInfo[] tables)
+            throws NotificationException {}
 }

src/main/java/com/lightstreamer/kafka_connector/adapters/pub/KafkaConnectorMetadataAdapter.java → connector/src/main/java/com/lightstreamer/kafka_connector/adapters/pub/KafkaConnectorMetadataAdapter.java

@@ -23,7 +23,6 @@
 import com.lightstreamer.interfaces.metadata.Mode;
 import com.lightstreamer.interfaces.metadata.NotificationException;
 import com.lightstreamer.interfaces.metadata.TableInfo;
-import com.lightstreamer.kafka_connector.adapters.ConnectorMetadataAdapter;
 import com.lightstreamer.kafka_connector.adapters.commons.MetadataListener;
 import com.lightstreamer.kafka_connector.adapters.config.ConfigException;
 import com.lightstreamer.kafka_connector.adapters.config.GlobalConfig;
@@ -65,8 +64,7 @@ public final void init(@SuppressWarnings("rawtypes") Map params, File configDir)
         doInit(params, configDir);
     }
 
-    protected void doInit(Map params, File configDir) throws MetadataProviderException {
-    }
+    protected void doInit(Map params, File configDir) throws MetadataProviderException {}
 
     // Used only for unit testing.
     public final Optional<Set<String>> itemsBySession(String sessionId) {
@@ -76,7 +74,7 @@ public final Optional<Set<String>> itemsBySession(String sessionId) {
     private void configureLogging(File configDir) throws ConfigException {
         String logConfigFile = globalConfig.getFile(GlobalConfig.LOGGING_CONFIGURATION_PATH);
         PropertyConfigurator.configure(logConfigFile);
-        this.log = LoggerFactory.getLogger(ConnectorMetadataAdapter.class);
+        this.log = LoggerFactory.getLogger(KafkaConnectorMetadataAdapter.class);
     }
 
     public static final MetadataListener listener(String dataProviderName, boolean enabled) {

gradle.properties

@@ -0,0 +1 @@
+version = 0.1.0

settings.gradle

@@ -1 +1,2 @@
 rootProject.name = 'lightstreamer-kafka-connector'
+include 'connector'