You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2021/05/13 16:43:29 UTC
[GitHub] [pulsar] bdunn313 opened a new issue #10579: Sinks API endpoint `getSinkInfo` does not properly return a list of topic inputs
bdunn313 opened a new issue #10579:
URL: https://github.com/apache/pulsar/issues/10579
**Describe the bug**
Currently, the [documented response shape](https://pulsar.apache.org/sink-rest-api/?version=2.7.1#operation/getSinkInfo) for `getSinkInfo` lists a node called `inputs` that should show a list of names of topics used as inputs for a given sink. Currently, requesting this endpoint returns a response where `inputs` always returns `null` instead of a list of topics.
**To Reproduce**
Steps to reproduce the behavior:
1. Create a tenant, namespace, and at least one topic
2. Create a new sink, setting the new topic(s) as topic input(s) to the sink
3. Request sink details via the `getSinkInfo` endpoint
4. See that `inputs` returns `null` instead of a list of topic(s) used to set up the sink.
**Expected behavior**
To receive a list of strings that match the topic names used during sink setup in step 2 of reproduction steps.
**Screenshots**
Sample request
```http
GET https://<baseUrl>/admin/v3/sink/tenant/default/elasticSearchSink
Authorization: <redacted>
Accept: application/json, text/plain, */*
```
Sample response
```http
HTTP/1.1 200 OK
Content-Type: application/json
Vary: Origin
Date: Thu, 13 May 2021 16:25:19 GMT
Content-Length: 1221
Connection: close
{
"tenant": "tenant",
"namespace": "default",
"name": "elasticSearchSink",
"className": "org.apache.pulsar.io.elasticsearch.ElasticSearchSink",
"sourceSubscriptionName": null,
"sourceSubscriptionPosition": null,
"inputs": null,
"topicToSerdeClassName": null,
"topicsPattern": null,
"topicToSchemaType": null,
"topicToSchemaProperties": null,
"inputSpecs": {
"persistent://tenant/default/new-topic": {
"schemaType": null,
"serdeClassName": null,
"schemaProperties": {},
"receiverQueueSize": null,
"regexPattern": false
}
},
"maxMessageRetries": null,
"deadLetterTopic": null,
"configs": {
"password": "<redacted>",
"elasticSearchUrl": "<redacted>",
"indexName": "<redacted>",
"username": "<redacted>"
},
"secrets": null,
"parallelism": 1,
"processingGuarantees": "ATLEAST_ONCE",
"retainOrdering": false,
"resources": null,
"autoAck": true,
"timeoutMs": 5000,
"negativeAckRedeliveryDelayMs": null,
"archive": "builtin://elastic_search",
"cleanupSubscription": null,
"runtimeFlags": null,
"customRuntimeOptions": "<redacted>"
}
```
**Desktop (please complete the following information):**
- OS: Mac OSX Catalina 10.15.7
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] codelipenghui closed issue #10579: Sinks API endpoint `getSinkInfo` does not properly return a list of topic inputs
Posted by GitBox <gi...@apache.org>.
codelipenghui closed issue #10579:
URL: https://github.com/apache/pulsar/issues/10579
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] codelipenghui closed issue #10579: Sinks API endpoint `getSinkInfo` does not properly return a list of topic inputs
Posted by GitBox <gi...@apache.org>.
codelipenghui closed issue #10579:
URL: https://github.com/apache/pulsar/issues/10579
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org