Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
5 changes: 5 additions & 0 deletions packages/connector-management-sdk/api/openapi.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -1313,8 +1313,13 @@ components:
type: string
ConnectorState:
enum:
- assigning
- assigned
- updating
- ready
- stopped
- failed
- deleting
- deleted
- provisioning
- deprovisioning
Expand Down
10 changes: 10 additions & 0 deletions packages/connector-management-sdk/docs/ConnectorState.md
Original file line number Diff line number Diff line change
Expand Up @@ -5,10 +5,20 @@
## Enum


* `ASSIGNING` (value: `"assigning"`)

* `ASSIGNED` (value: `"assigned"`)

* `UPDATING` (value: `"updating"`)

* `READY` (value: `"ready"`)

* `STOPPED` (value: `"stopped"`)

* `FAILED` (value: `"failed"`)

* `DELETING` (value: `"deleting"`)

* `DELETED` (value: `"deleted"`)

* `PROVISIONING` (value: `"provisioning"`)
Expand Down
4 changes: 2 additions & 2 deletions packages/connector-management-sdk/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -260,8 +260,8 @@
</dependencies>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<swagger-annotations-version>1.6.5</swagger-annotations-version>
<resteasy-version>5.0.2.Final</resteasy-version>
<swagger-annotations-version>1.5.22</swagger-annotations-version>
<resteasy-version>5.0.1.Final</resteasy-version>
<jackson-version>2.10.5</jackson-version>
<jackson-databind-version>2.10.5.1</jackson-databind-version>
<jackson-databind-nullable-version>0.2.1</jackson-databind-nullable-version>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -26,10 +26,20 @@
*/
public enum ConnectorState {

ASSIGNING("assigning"),

ASSIGNED("assigned"),

UPDATING("updating"),

READY("ready"),

STOPPED("stopped"),

FAILED("failed"),

DELETING("deleting"),

DELETED("deleted"),

PROVISIONING("provisioning"),
Expand Down
11 changes: 6 additions & 5 deletions packages/kafka-instance-sdk/api/openapi.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -26,13 +26,13 @@ paths:
those records the requestor is authorized to view.
operationId: getTopics
parameters:
- description: Maximum number of topics to return on single page
- deprecated: true
description: Maximum number of topics to return
explode: true
in: query
name: size
name: limit
required: false
schema:
format: int32
type: integer
style: form
- description: Filter to apply when returning the list of topics
Expand Down Expand Up @@ -508,10 +508,11 @@ paths:
authorized to view.
operationId: getConsumerGroups
parameters:
- description: Maximum number of consumer groups to return on single page
- deprecated: true
description: Maximum number of consumer groups to return
explode: true
in: query
name: size
name: limit
required: false
schema:
type: integer
Expand Down
8 changes: 4 additions & 4 deletions packages/kafka-instance-sdk/docs/GroupsApi.md
Original file line number Diff line number Diff line change
Expand Up @@ -171,7 +171,7 @@ Name | Type | Description | Notes

## getConsumerGroups

> ConsumerGroupList getConsumerGroups(size, page, topic, groupIdFilter, order, orderKey)
> ConsumerGroupList getConsumerGroups(limit, page, topic, groupIdFilter, order, orderKey)

List of consumer groups in the Kafka instance.

Expand All @@ -198,14 +198,14 @@ public class Example {
Bearer.setAccessToken("YOUR ACCESS TOKEN");

GroupsApi apiInstance = new GroupsApi(defaultClient);
Integer size = 56; // Integer | Maximum number of consumer groups to return on single page
Integer limit = 56; // Integer | Maximum number of consumer groups to return
Integer page = 56; // Integer | The page when returning the list of consumer groups
String topic = "topic_example"; // String | Return consumer groups where the topic name contains with this value
String groupIdFilter = "groupIdFilter_example"; // String | Return the consumer groups where the ID contains with this value
String order = "asc"; // String | Order of the consumer groups sorting. Ascending order is used as default.
String orderKey = "name"; // String | Order key to sort the items by. Only the value 'name' is currently applicable.
try {
ConsumerGroupList result = apiInstance.getConsumerGroups(size, page, topic, groupIdFilter, order, orderKey);
ConsumerGroupList result = apiInstance.getConsumerGroups(limit, page, topic, groupIdFilter, order, orderKey);
System.out.println(result);
} catch (ApiException e) {
System.err.println("Exception when calling GroupsApi#getConsumerGroups");
Expand All @@ -223,7 +223,7 @@ public class Example {

Name | Type | Description | Notes
------------- | ------------- | ------------- | -------------
**size** | **Integer**| Maximum number of consumer groups to return on single page | [optional]
**limit** | **Integer**| Maximum number of consumer groups to return | [optional]
**page** | **Integer**| The page when returning the list of consumer groups | [optional]
**topic** | **String**| Return consumer groups where the topic name contains with this value | [optional]
**groupIdFilter** | **String**| Return the consumer groups where the ID contains with this value | [optional]
Expand Down
8 changes: 4 additions & 4 deletions packages/kafka-instance-sdk/docs/TopicsApi.md
Original file line number Diff line number Diff line change
Expand Up @@ -239,7 +239,7 @@ Name | Type | Description | Notes

## getTopics

> TopicsList getTopics(size, filter, page, order, orderKey)
> TopicsList getTopics(limit, filter, page, order, orderKey)

List of topics

Expand All @@ -266,13 +266,13 @@ public class Example {
Bearer.setAccessToken("YOUR ACCESS TOKEN");

TopicsApi apiInstance = new TopicsApi(defaultClient);
Integer size = 56; // Integer | Maximum number of topics to return on single page
Integer limit = 56; // Integer | Maximum number of topics to return
String filter = "filter_example"; // String | Filter to apply when returning the list of topics
Integer page = 56; // Integer | The page when returning the limit of requested topics.
String order = "asc"; // String | Order of the items sorting. Ascending order is used as default.
String orderKey = "name"; // String | Order key to sort the topics by.
try {
TopicsList result = apiInstance.getTopics(size, filter, page, order, orderKey);
TopicsList result = apiInstance.getTopics(limit, filter, page, order, orderKey);
System.out.println(result);
} catch (ApiException e) {
System.err.println("Exception when calling TopicsApi#getTopics");
Expand All @@ -290,7 +290,7 @@ public class Example {

Name | Type | Description | Notes
------------- | ------------- | ------------- | -------------
**size** | **Integer**| Maximum number of topics to return on single page | [optional]
**limit** | **Integer**| Maximum number of topics to return | [optional]
**filter** | **String**| Filter to apply when returning the list of topics | [optional]
**page** | **Integer**| The page when returning the limit of requested topics. | [optional]
**order** | **String**| Order of the items sorting. Ascending order is used as default. | [optional] [enum: asc, desc]
Expand Down
4 changes: 2 additions & 2 deletions packages/kafka-instance-sdk/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -260,8 +260,8 @@
</dependencies>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<swagger-annotations-version>1.6.5</swagger-annotations-version>
<resteasy-version>5.0.2.Final</resteasy-version>
<swagger-annotations-version>1.5.22</swagger-annotations-version>
<resteasy-version>5.0.1.Final</resteasy-version>
<jackson-version>2.10.5</jackson-version>
<jackson-databind-version>2.10.5.1</jackson-databind-version>
<jackson-databind-nullable-version>0.2.1</jackson-databind-nullable-version>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -136,7 +136,7 @@ public ConsumerGroup getConsumerGroupById(String consumerGroupId, String order,
/**
* List of consumer groups in the Kafka instance.
* Returns a list of all consumer groups for a particular Kafka instance. The consumer groups returned are limited to those records the requestor is authorized to view.
* @param size Maximum number of consumer groups to return on single page (optional)
* @param limit Maximum number of consumer groups to return (optional)
* @param page The page when returning the list of consumer groups (optional)
* @param topic Return consumer groups where the topic name contains with this value (optional)
* @param groupIdFilter Return the consumer groups where the ID contains with this value (optional)
Expand All @@ -145,7 +145,7 @@ public ConsumerGroup getConsumerGroupById(String consumerGroupId, String order,
* @return a {@code ConsumerGroupList}
* @throws ApiException if fails to make API call
*/
public ConsumerGroupList getConsumerGroups(Integer size, Integer page, String topic, String groupIdFilter, String order, String orderKey) throws ApiException {
public ConsumerGroupList getConsumerGroups(Integer limit, Integer page, String topic, String groupIdFilter, String order, String orderKey) throws ApiException {
Object localVarPostBody = null;

// create path and map variables
Expand All @@ -157,7 +157,7 @@ public ConsumerGroupList getConsumerGroups(Integer size, Integer page, String to
Map<String, String> localVarCookieParams = new HashMap<String, String>();
Map<String, Object> localVarFormParams = new HashMap<String, Object>();

localVarQueryParams.addAll(apiClient.parameterToPairs("", "size", size));
localVarQueryParams.addAll(apiClient.parameterToPairs("", "limit", limit));
localVarQueryParams.addAll(apiClient.parameterToPairs("", "page", page));
localVarQueryParams.addAll(apiClient.parameterToPairs("", "topic", topic));
localVarQueryParams.addAll(apiClient.parameterToPairs("", "group-id-filter", groupIdFilter));
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -171,15 +171,15 @@ public Topic getTopic(String topicName) throws ApiException {
/**
* List of topics
* Returns a list of all of the available topics, or the list of topics that meet the request query parameters. The topics returned are limited to those records the requestor is authorized to view.
* @param size Maximum number of topics to return on single page (optional)
* @param limit Maximum number of topics to return (optional)
* @param filter Filter to apply when returning the list of topics (optional)
* @param page The page when returning the limit of requested topics. (optional)
* @param order Order of the items sorting. Ascending order is used as default. (optional)
* @param orderKey Order key to sort the topics by. (optional)
* @return a {@code TopicsList}
* @throws ApiException if fails to make API call
*/
public TopicsList getTopics(Integer size, String filter, Integer page, String order, String orderKey) throws ApiException {
public TopicsList getTopics(Integer limit, String filter, Integer page, String order, String orderKey) throws ApiException {
Object localVarPostBody = null;

// create path and map variables
Expand All @@ -191,7 +191,7 @@ public TopicsList getTopics(Integer size, String filter, Integer page, String or
Map<String, String> localVarCookieParams = new HashMap<String, String>();
Map<String, Object> localVarFormParams = new HashMap<String, Object>();

localVarQueryParams.addAll(apiClient.parameterToPairs("", "size", size));
localVarQueryParams.addAll(apiClient.parameterToPairs("", "limit", limit));
localVarQueryParams.addAll(apiClient.parameterToPairs("", "filter", filter));
localVarQueryParams.addAll(apiClient.parameterToPairs("", "page", page));
localVarQueryParams.addAll(apiClient.parameterToPairs("", "order", order));
Expand Down
4 changes: 2 additions & 2 deletions packages/kafka-management-sdk/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -260,8 +260,8 @@
</dependencies>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<swagger-annotations-version>1.6.5</swagger-annotations-version>
<resteasy-version>5.0.2.Final</resteasy-version>
<swagger-annotations-version>1.5.22</swagger-annotations-version>
<resteasy-version>5.0.1.Final</resteasy-version>
<jackson-version>2.10.5</jackson-version>
<jackson-databind-version>2.10.5.1</jackson-databind-version>
<jackson-databind-nullable-version>0.2.1</jackson-databind-nullable-version>
Expand Down
4 changes: 2 additions & 2 deletions packages/registry-management-sdk/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -260,8 +260,8 @@
</dependencies>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<swagger-annotations-version>1.6.5</swagger-annotations-version>
<resteasy-version>5.0.2.Final</resteasy-version>
<swagger-annotations-version>1.5.22</swagger-annotations-version>
<resteasy-version>5.0.1.Final</resteasy-version>
<jackson-version>2.10.5</jackson-version>
<jackson-databind-version>2.10.5.1</jackson-databind-version>
<jackson-databind-nullable-version>0.2.1</jackson-databind-nullable-version>
Expand Down