diff --git a/examples/pom.xml b/examples/pom.xml
new file mode 100644
index 00000000..676df211
--- /dev/null
+++ b/examples/pom.xml
@@ -0,0 +1,125 @@
+
+
+ 4.0.0
+
+ com.redhat.cloud
+ sdk-tests
+ 0.1.0-SNAPSHOT
+ jar
+ sdk-tests
+ http://console.redhat.com
+
+ com.redhat.cloud
+ rhoas-sdk-java
+ 0.1.0-SNAPSHOT
+
+
+ 11
+ 11
+ 5.7.2
+ 1.7.2
+
+
+
+
+ com.redhat.cloud
+ kafka-management-sdk
+ 1.1.2
+
+
+ com.redhat.cloud
+ registry-management-sdk
+ 0.5.1
+
+
+ com.redhat.cloud
+ kafka-instance-sdk
+ 0.3.0
+
+
+
+ javax.annotation
+ javax.annotation-api
+ 1.3.2
+
+
+ org.junit.jupiter
+ junit-jupiter-api
+ ${junit.jupiter.version}
+ test
+
+
+ org.junit.jupiter
+ junit-jupiter-params
+ ${junit.jupiter.version}
+ test
+
+
+ org.junit.jupiter
+ junit-jupiter-engine
+ ${junit.jupiter.version}
+ test
+
+
+ org.junit.platform
+ junit-platform-commons
+ ${junit.platform.version}
+ test
+
+
+
+
+
+
+ io.fabric8
+ docker-maven-plugin
+ 0.37.0
+
+
+ start
+ pre-integration-test
+
+ start
+
+
+
+ stop
+ post-integration-test
+
+ stop
+
+
+
+
+
+
+
+
+ quay.io/wtrocki/api-mock
+
+
+ 8080:8000
+
+
+
+
+
+
+
+
+
+ org.apache.maven.plugins
+ maven-failsafe-plugin
+ 2.22.2
+
+
+
+ integration-test
+ verify
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/examples/src/test/java/com/redhat/cloud/KafkaInstanceIT.java b/examples/src/test/java/com/redhat/cloud/KafkaInstanceIT.java
new file mode 100644
index 00000000..4ddc49a9
--- /dev/null
+++ b/examples/src/test/java/com/redhat/cloud/KafkaInstanceIT.java
@@ -0,0 +1,40 @@
+package com.redhat.cloud;
+
+import static org.junit.jupiter.api.Assertions.*;
+
+import java.util.concurrent.TimeUnit;
+
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.Timeout;
+
+import com.openshift.cloud.api.kas.auth.TopicsApi;
+import com.openshift.cloud.api.kas.auth.invoker.*;
+import com.openshift.cloud.api.kas.auth.invoker.auth.OAuth;
+import com.openshift.cloud.api.kas.auth.models.*;
+
+
+public class KafkaInstanceIT {
+
+ @Test
+ public void testCreateExample() {
+ ApiClient defaultClient = Configuration.getDefaultApiClient();
+ defaultClient.setBasePath("http://localhost:8080/rest");
+
+ OAuth oauth = (OAuth) defaultClient.getAuthentication("Bearer");
+ oauth.setAccessToken("accessToken");
+
+ TopicsApi apiInstance = new TopicsApi(defaultClient);
+
+ try {
+ TopicsList result = apiInstance.getTopics(null, null, null, null, null, null, null);
+ assertNotNull(result);
+ assertEquals(1, result.getItems().size());
+ } catch (ApiException e) {
+ System.err.println("Exception when calling TopicsApi#getTopics");
+ System.err.println("Status code: " + e.getCode());
+ System.err.println("Reason: " + e.getResponseBody());
+ System.err.println("Response headers: " + e.getResponseHeaders());
+ e.printStackTrace();
+ }
+ }
+}
diff --git a/examples/src/test/java/com/redhat/cloud/KafkaManagementIT.java b/examples/src/test/java/com/redhat/cloud/KafkaManagementIT.java
new file mode 100644
index 00000000..e74c6a8c
--- /dev/null
+++ b/examples/src/test/java/com/redhat/cloud/KafkaManagementIT.java
@@ -0,0 +1,61 @@
+package com.redhat.cloud;
+
+import static org.junit.jupiter.api.Assertions.*;
+
+import org.junit.jupiter.api.Test;
+import com.openshift.cloud.api.kas.invoker.*;
+import com.openshift.cloud.api.kas.invoker.auth.*;
+import com.openshift.cloud.api.kas.models.*;
+import com.openshift.cloud.api.kas.DefaultApi;
+
+public class KafkaManagementIT {
+ @Test
+ public void testCreateExample() {
+ ApiClient defaultClient = Configuration.getDefaultApiClient();
+ defaultClient.setBasePath("http://localhost:8080");
+
+ // Configure HTTP bearer authorization: Bearer
+ HttpBearerAuth Bearer = (HttpBearerAuth) defaultClient.getAuthentication("Bearer");
+ Bearer.setBearerToken("BEARER TOKEN");
+
+ DefaultApi apiInstance = new DefaultApi(defaultClient);
+ Boolean async = true; // Boolean | Perform the action in an asynchronous manner
+ KafkaRequestPayload kafkaRequestPayload = new KafkaRequestPayload(); // KafkaRequestPayload | Kafka data
+ kafkaRequestPayload.setName("name");
+ try {
+ KafkaRequest result = apiInstance.createKafka(async, kafkaRequestPayload);
+ assertNotNull(result);
+ } catch (ApiException e) {
+ System.err.println("Exception when calling DefaultApi#createKafka");
+ System.err.println("Status code: " + e.getCode());
+ System.err.println("Reason: " + e.getResponseBody());
+ System.err.println("Response headers: " + e.getResponseHeaders());
+ e.printStackTrace();
+ }
+ }
+
+ @Test
+ public void testListExample() {
+ ApiClient defaultClient = Configuration.getDefaultApiClient();
+ defaultClient.setBasePath("http://localhost:8080");
+
+ // Configure HTTP bearer authorization: Bearer
+ HttpBearerAuth Bearer = (HttpBearerAuth) defaultClient.getAuthentication("Bearer");
+ Bearer.setBearerToken("BEARER TOKEN");
+
+ DefaultApi apiInstance = new DefaultApi(defaultClient);
+
+ try {
+ KafkaRequestList result = apiInstance.getKafkas(null,null,null,null);
+
+ assertNotNull(result);
+ assertEquals(1, result.getItems().size());
+ } catch (ApiException e) {
+ System.err.println("Exception when calling DefaultApi#createKafka");
+ System.err.println("Status code: " + e.getCode());
+ System.err.println("Reason: " + e.getResponseBody());
+ System.err.println("Response headers: " + e.getResponseHeaders());
+ e.printStackTrace();
+ }
+ }
+}
diff --git a/examples/src/test/java/com/redhat/cloud/ServiceAccountIT.java b/examples/src/test/java/com/redhat/cloud/ServiceAccountIT.java
new file mode 100644
index 00000000..7531f576
--- /dev/null
+++ b/examples/src/test/java/com/redhat/cloud/ServiceAccountIT.java
@@ -0,0 +1,45 @@
+package com.redhat.cloud;
+
+import static org.junit.jupiter.api.Assertions.*;
+
+import org.junit.jupiter.api.Test;
+
+import com.openshift.cloud.api.kas.SecurityApi;
+import com.openshift.cloud.api.kas.invoker.Configuration;
+import com.openshift.cloud.api.kas.models.ServiceAccount;
+import com.openshift.cloud.api.kas.models.ServiceAccountRequest;
+import com.openshift.cloud.api.kas.invoker.auth.HttpBearerAuth;
+import com.openshift.cloud.api.kas.invoker.ApiClient;
+import com.openshift.cloud.api.kas.invoker.ApiException;
+
+public class ServiceAccountIT {
+
+ @Test
+ public void testCreateExample() {
+ ApiClient defaultClient = Configuration.getDefaultApiClient();
+ defaultClient.setBasePath("http://localhost:8080");
+
+ // Configure HTTP bearer authorization: Bearer
+ HttpBearerAuth Bearer = (HttpBearerAuth) defaultClient.getAuthentication("Bearer");
+ Bearer.setBearerToken("TOKEN");
+
+ var apiInstance = new SecurityApi(defaultClient);
+ var serviceAccountRequest = new ServiceAccountRequest();
+ serviceAccountRequest.setDescription("Description");
+ serviceAccountRequest.setName("sa_name");
+ try {
+ ServiceAccount result = apiInstance.createServiceAccount(serviceAccountRequest);
+
+ assertNotNull(result);
+
+ } catch (ApiException e) {
+ System.err.println("Exception when calling DefaultApi#createKafka");
+ System.err.println("Status code: " + e.getCode());
+ System.err.println("Reason: " + e.getResponseBody());
+ System.err.println("Response headers: " + e.getResponseHeaders());
+ e.printStackTrace();
+ }
+ }
+
+
+}
diff --git a/examples/src/test/java/com/redhat/cloud/ServiceRegistryIT.java b/examples/src/test/java/com/redhat/cloud/ServiceRegistryIT.java
new file mode 100644
index 00000000..6fbf9f2b
--- /dev/null
+++ b/examples/src/test/java/com/redhat/cloud/ServiceRegistryIT.java
@@ -0,0 +1,37 @@
+package com.redhat.cloud;
+
+import static org.junit.jupiter.api.Assertions.*;
+
+import org.junit.jupiter.api.Test;
+
+import com.openshift.cloud.api.srs.*;
+import com.openshift.cloud.api.srs.invoker.*;
+import com.openshift.cloud.api.srs.invoker.auth.*;
+import com.openshift.cloud.api.srs.models.*;
+
+
+public class ServiceRegistryIT {
+
+ @Test
+ public void testListExample() {
+ var defaultClient = Configuration.getDefaultApiClient();
+ defaultClient.setBasePath("http://localhost:8080");
+
+ var oauth = (HttpBearerAuth) defaultClient.getAuthentication("Bearer");
+ oauth.setBearerToken("bearerToken");
+
+ var apiInstance = new RegistriesApi(defaultClient);
+
+ try {
+ RegistryListRest result = apiInstance.getRegistries(null, null, null, null);
+ assertNotNull(result);
+ assertEquals(1, result.getItems().size());
+ } catch (ApiException e) {
+ System.err.println("Exception when calling RegistriesApi#getRegistries");
+ System.err.println("Status code: " + e.getCode());
+ System.err.println("Reason: " + e.getResponseBody());
+ System.err.println("Response headers: " + e.getResponseHeaders());
+ e.printStackTrace();
+ }
+ }
+}
diff --git a/pom.xml b/pom.xml
index e8445ebc..20438bb4 100644
--- a/pom.xml
+++ b/pom.xml
@@ -14,6 +14,7 @@
packages/kafka-management-sdk
packages/registry-management-sdk
packages/kafka-instance-sdk
+ examples
@@ -85,4 +86,4 @@
-
\ No newline at end of file
+