feat(extensions): add Title, Description, and configProperties to all extensions

Add Title and Description annotations to ~50 extension classes across
all providers (kafka, kafka-connect, schema-registry, aiven, aws, core)
so that the redesigned api-extensions list command can display meaningful
titles. Add configProperties() overrides to LocalResourceRepository and
GitHubResourceRepository so their configuration is discoverable via the
API. Add title truncation (30 chars) to the CLI table output.

Author: fhussonnois

cli/src/main/java/io/streamthoughts/jikkou/client/command/extension/ListExtensionCommand.java

@@ -82,7 +82,7 @@ public Integer call() throws IOException {
                             extension.provider(),
                             extension.category(),
                             extension.name(),
-                            Objects.toString(extension.title(), ""),
+                            truncate(Objects.toString(extension.title(), ""), 30),
                             String.valueOf(extension.enabled())
                     })
                     .toArray(String[][]::new);
@@ -105,4 +105,11 @@ public Integer call() throws IOException {
         }
         return CommandLine.ExitCode.OK;
     }
+
+    private static String truncate(String value, int maxLength) {
+        if (value == null || value.length() <= maxLength) {
+            return value;
+        }
+        return value.substring(0, maxLength - 3) + "...";
+    }
 }

providers/jikkou-provider-aiven/src/main/java/io/streamthoughts/jikkou/extension/aiven/reconciler/AivenKafkaQuotaCollector.java

@@ -8,7 +8,9 @@
 
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.JsonNode;
+import io.streamthoughts.jikkou.core.annotation.Description;
 import io.streamthoughts.jikkou.core.annotation.SupportedResource;
+import io.streamthoughts.jikkou.core.annotation.Title;
 import io.streamthoughts.jikkou.core.config.Configuration;
 import io.streamthoughts.jikkou.core.exceptions.ConfigException;
 import io.streamthoughts.jikkou.core.extension.ExtensionContext;
@@ -30,6 +32,8 @@
 import java.util.stream.Collectors;
 import org.jetbrains.annotations.NotNull;
 
+@Title("Collect Aiven Kafka quotas")
+@Description("Collects Kafka quota resources from an Aiven service.")
 @SupportedResource(type = V1KafkaQuota.class)
 public class AivenKafkaQuotaCollector implements Collector<V1KafkaQuota> {
 

providers/jikkou-provider-aiven/src/main/java/io/streamthoughts/jikkou/extension/aiven/reconciler/AivenKafkaQuotaController.java

@@ -12,7 +12,9 @@
 import static io.streamthoughts.jikkou.core.ReconciliationMode.UPDATE;
 
 import io.streamthoughts.jikkou.core.ReconciliationContext;
+import io.streamthoughts.jikkou.core.annotation.Description;
 import io.streamthoughts.jikkou.core.annotation.SupportedResource;
+import io.streamthoughts.jikkou.core.annotation.Title;
 import io.streamthoughts.jikkou.core.config.ConfigProperty;
 import io.streamthoughts.jikkou.core.exceptions.ConfigException;
 import io.streamthoughts.jikkou.core.extension.ExtensionContext;
@@ -36,6 +38,8 @@
 import java.util.concurrent.atomic.AtomicBoolean;
 import org.jetbrains.annotations.NotNull;
 
+@Title("Reconcile Aiven Kafka quotas")
+@Description("Reconciles Kafka quota resources on an Aiven service to match the desired state.")
 @ControllerConfiguration(
         supportedModes = {CREATE, DELETE, UPDATE, FULL}
 )

providers/jikkou-provider-aiven/src/main/java/io/streamthoughts/jikkou/extension/aiven/reconciler/AivenKafkaTopicAclEntryCollector.java

@@ -8,7 +8,9 @@
 
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.JsonNode;
+import io.streamthoughts.jikkou.core.annotation.Description;
 import io.streamthoughts.jikkou.core.annotation.SupportedResource;
+import io.streamthoughts.jikkou.core.annotation.Title;
 import io.streamthoughts.jikkou.core.config.Configuration;
 import io.streamthoughts.jikkou.core.exceptions.ConfigException;
 import io.streamthoughts.jikkou.core.extension.ExtensionContext;
@@ -30,6 +32,8 @@
 import java.util.stream.Collectors;
 import org.jetbrains.annotations.NotNull;
 
+@Title("Collect Aiven Kafka topic ACLs")
+@Description("Collects Kafka topic ACL entry resources from an Aiven service.")
 @SupportedResource(type = V1KafkaTopicAclEntry.class)
 public class AivenKafkaTopicAclEntryCollector implements Collector<V1KafkaTopicAclEntry> {
 

providers/jikkou-provider-aiven/src/main/java/io/streamthoughts/jikkou/extension/aiven/reconciler/AivenKafkaTopicAclEntryController.java

@@ -11,7 +11,9 @@
 import static io.streamthoughts.jikkou.core.ReconciliationMode.FULL;
 
 import io.streamthoughts.jikkou.core.ReconciliationContext;
+import io.streamthoughts.jikkou.core.annotation.Description;
 import io.streamthoughts.jikkou.core.annotation.SupportedResource;
+import io.streamthoughts.jikkou.core.annotation.Title;
 import io.streamthoughts.jikkou.core.config.ConfigProperty;
 import io.streamthoughts.jikkou.core.exceptions.ConfigException;
 import io.streamthoughts.jikkou.core.extension.ExtensionContext;
@@ -35,6 +37,8 @@
 import java.util.concurrent.atomic.AtomicBoolean;
 import org.jetbrains.annotations.NotNull;
 
+@Title("Reconcile Aiven Kafka topic ACLs")
+@Description("Reconciles Kafka topic ACL entry resources on an Aiven service to match the desired state.")
 @ControllerConfiguration(
         supportedModes = {CREATE, DELETE, FULL}
 )

providers/jikkou-provider-aiven/src/main/java/io/streamthoughts/jikkou/extension/aiven/reconciler/AivenKafkaTopicCollector.java

@@ -10,7 +10,9 @@
 
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.JsonNode;
+import io.streamthoughts.jikkou.core.annotation.Description;
 import io.streamthoughts.jikkou.core.annotation.SupportedResource;
+import io.streamthoughts.jikkou.core.annotation.Title;
 import io.streamthoughts.jikkou.core.config.ConfigProperty;
 import io.streamthoughts.jikkou.core.config.Configuration;
 import io.streamthoughts.jikkou.core.exceptions.ConfigException;
@@ -41,6 +43,8 @@
 import java.util.function.Predicate;
 import org.jetbrains.annotations.NotNull;
 
+@Title("Collect Aiven Kafka topics")
+@Description("Collects Kafka topic resources from an Aiven service.")
 @SupportedResource(kind = "KafkaTopic", apiVersion = ApiVersions.KAFKA_AIVEN_V1BETA2)
 public class AivenKafkaTopicCollector extends ContextualExtension implements Collector<V1KafkaTopic> {
 

providers/jikkou-provider-aiven/src/main/java/io/streamthoughts/jikkou/extension/aiven/reconciler/AivenKafkaTopicController.java

@@ -13,7 +13,9 @@
 import static io.streamthoughts.jikkou.extension.aiven.ApiVersions.KAFKA_AIVEN_V1BETA2;
 
 import io.streamthoughts.jikkou.core.ReconciliationContext;
+import io.streamthoughts.jikkou.core.annotation.Description;
 import io.streamthoughts.jikkou.core.annotation.SupportedResource;
+import io.streamthoughts.jikkou.core.annotation.Title;
 import io.streamthoughts.jikkou.core.config.ConfigProperty;
 import io.streamthoughts.jikkou.core.config.Configuration;
 import io.streamthoughts.jikkou.core.extension.ContextualExtension;
@@ -44,6 +46,8 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+@Title("Reconcile Aiven Kafka topics")
+@Description("Reconciles Kafka topic resources on an Aiven service to match the desired state.")
 @SupportedResource(apiVersion = KAFKA_AIVEN_V1BETA2, kind = "KafkaTopicChange")
 @SupportedResource(apiVersion = KAFKA_AIVEN_V1BETA2, kind = "KafkaTopic")
 @ControllerConfiguration(

providers/jikkou-provider-aiven/src/main/java/io/streamthoughts/jikkou/extension/aiven/reconciler/AivenSchemaRegistryAclEntryCollector.java

@@ -8,7 +8,9 @@
 
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.JsonNode;
+import io.streamthoughts.jikkou.core.annotation.Description;
 import io.streamthoughts.jikkou.core.annotation.SupportedResource;
+import io.streamthoughts.jikkou.core.annotation.Title;
 import io.streamthoughts.jikkou.core.config.Configuration;
 import io.streamthoughts.jikkou.core.exceptions.ConfigException;
 import io.streamthoughts.jikkou.core.exceptions.JikkouRuntimeException;
@@ -31,6 +33,8 @@
 import java.util.stream.Collectors;
 import org.jetbrains.annotations.NotNull;
 
+@Title("Collect Aiven Schema Registry ACLs")
+@Description("Collects Schema Registry ACL entry resources from an Aiven service.")
 @SupportedResource(type = V1SchemaRegistryAclEntry.class)
 public final class AivenSchemaRegistryAclEntryCollector implements Collector<V1SchemaRegistryAclEntry> {
 

providers/jikkou-provider-aiven/src/main/java/io/streamthoughts/jikkou/extension/aiven/reconciler/AivenSchemaRegistryAclEntryController.java

@@ -11,7 +11,9 @@
 import static io.streamthoughts.jikkou.core.ReconciliationMode.FULL;
 
 import io.streamthoughts.jikkou.core.ReconciliationContext;
+import io.streamthoughts.jikkou.core.annotation.Description;
 import io.streamthoughts.jikkou.core.annotation.SupportedResource;
+import io.streamthoughts.jikkou.core.annotation.Title;
 import io.streamthoughts.jikkou.core.config.ConfigProperty;
 import io.streamthoughts.jikkou.core.extension.ExtensionContext;
 import io.streamthoughts.jikkou.core.models.change.ResourceChange;
@@ -34,6 +36,8 @@
 import java.util.concurrent.atomic.AtomicBoolean;
 import org.jetbrains.annotations.NotNull;
 
+@Title("Reconcile Aiven Schema Registry ACLs")
+@Description("Reconciles Schema Registry ACL entry resources on an Aiven service to match the desired state.")
 @ControllerConfiguration(
         supportedModes = {CREATE, DELETE, FULL}
 )

providers/jikkou-provider-aiven/src/main/java/io/streamthoughts/jikkou/extension/aiven/reconciler/AivenSchemaRegistrySubjectCollector.java

@@ -10,7 +10,9 @@
 import com.fasterxml.jackson.databind.JsonNode;
 import io.streamthoughts.jikkou.common.utils.AsyncUtils;
 import io.streamthoughts.jikkou.common.utils.Pair;
+import io.streamthoughts.jikkou.core.annotation.Description;
 import io.streamthoughts.jikkou.core.annotation.SupportedResource;
+import io.streamthoughts.jikkou.core.annotation.Title;
 import io.streamthoughts.jikkou.core.config.Configuration;
 import io.streamthoughts.jikkou.core.exceptions.ConfigException;
 import io.streamthoughts.jikkou.core.exceptions.JikkouRuntimeException;
@@ -38,6 +40,8 @@
 /**
  * Aiven - Schema Registry Subjects Collector.
  */
+@Title("Collect Aiven Schema Registry subjects")
+@Description("Collects Schema Registry subject resources from an Aiven service.")
 @SupportedResource(
         apiVersion = ApiVersions.KAFKA_AIVEN_V1BETA1,
         kind = ApiVersions.SCHEMA_REGISTRY_KIND