kafka + sql storage variant, reusing streams variant datamodel (#1012)

* kafka + sql storage variant, reusing streams variant datamodel

* ksql - integration tests

* fix streams storage

app/src/main/java/io/apicurio/registry/storage/RegistryStorageProducer.java

@@ -38,10 +38,18 @@ public class RegistryStorageProducer {
     @Inject
     Instance<RegistryStorage> storages;
 
+    @Inject
+    Instance<RegistryStorageProvider> provider;
+
     @Produces
     @ApplicationScoped
     @Current
     public RegistryStorage realImpl() {
+
+        if (provider.isResolvable()) {
+            return provider.get().storage();
+        }
+
         List<RegistryStorage> list = storages.stream().collect(Collectors.toList());
         RegistryStorage impl = null;
         if (list.size() == 1) {

storage/ksql/src/main/java/io/apicurio/registry/storage/impl/ksql/TestTypes.java → app/src/main/java/io/apicurio/registry/storage/RegistryStorageProvider.java

@@ -13,19 +13,13 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-
-package io.apicurio.registry.storage.impl.ksql;
+package io.apicurio.registry.storage;
 
 /**
- * @author [email protected]
+ * @author Fabian Martinez
  */
-public class TestTypes {
-
-    public static void main(String[] args) {
-        System.out.println(long.class);
-        System.out.println(Long.class);
-        System.out.println(Long.class == long.class);
-        System.out.println(Long.class.equals(long.class));
-    }
+public interface RegistryStorageProvider {
+
+    RegistryStorage storage();
 
 }

perftest/pom.xml

@@ -14,6 +14,7 @@
         <dependency>
             <groupId>io.gatling.highcharts</groupId>
             <artifactId>gatling-charts-highcharts</artifactId>
+            <version>3.4.1</version>
             <scope>test</scope>
         </dependency>
     </dependencies>