Unstructured-IO / Unstructured-IO/unstructured-python-client
bug/SaaS API Kafka Cloud Connector inconsistency
まだ誰も着手していません。
- 主要言語
- Python
- スター
- 119
- フォーク
- 22
- 平均マージ
- 1日 21時間
- マージ済み PR(30日)
- 1
説明
Describe the bug
When attempting to create a Kafka Cloud source connector directly with the API, there appears to be no minimum viable configuration that can successfully create the connector because the server is inconsistent about the requirement for a bootstrap_server{,s} key.
First, attempting to create the connector with bootstrap_servers:
POST /api/v1/sources/ HTTP/1.1
Accept: application/json, */*;q=0.5
Accept-Encoding: gzip, deflate
Connection: keep-alive
Content-Length: 168
Content-Type: application/json
Host: platform.unstructuredapp.io
User-Agent: HTTPie/3.2.4
unstructured-api-key: ******
{
"config": {
"bootstrap_servers": "https://example.com",
"kafka_api_key": "foo",
"secret": "foo",
"topic": "foo"
},
"name": "test-kafka-connector",
"type": "kafka-cloud"
}
HTTP/1.1 412 Precondition Failed
content-length: 71
content-type: application/json
date: Wed, 20 Aug 2025 20:22:42 GMT
server: istio-envoy
x-envoy-upstream-service-time: 50
{
"errors": [
{
"field": "bootstrap_server",
"message": "Field is required"
}
]
}
The error message indicates that it should be bootstrap_server.
POST /api/v1/sources/ HTTP/1.1
Accept: application/json, */*;q=0.5
Accept-Encoding: gzip, deflate
Connection: keep-alive
Content-Length: 167
Content-Type: application/json
Host: platform.unstructuredapp.io
User-Agent: HTTPie/3.2.4
unstructured-api-key: ******
{
"config": {
"bootstrap_server": "https://example.com",
"kafka_api_key": "foo",
"secret": "foo",
"topic": "foo"
},
"name": "test-kafka-connector",
"type": "kafka-cloud"
}
HTTP/1.1 422 Unprocessable Entity
content-length: 191
content-type: application/json
date: Wed, 20 Aug 2025 20:23:50 GMT
server: istio-envoy
x-envoy-upstream-service-time: 80
{
"detail": [
{
"input": {
"bootstrap_server": "https://example.com",
"kafka_api_key": "foo",
"secret": "foo",
"topic": "foo"
},
"loc": [
"body",
"bootstrap_servers"
],
"msg": "Field required",
"type": "missing"
}
]
}
Now the error message says that bootstrap_servers is missing.
To Reproduce
Using HTTPie:
$ http -jv POST https://platform.unstructuredapp.io/api/v1/sources/ unstructured-api-key:$UNSTRUCTURED_API_KEY name=test-kafka-connector type=kafka-cloud config:='{"topic":"foo","kafka_api_key":"foo","secret":"foo","bootstrap_servers":"https://example.com"}'
$ http -jv POST https://platform.unstructuredapp.io/api/v1/sources/ unstructured-api-key:$UNSTRUCTURED_API_KEY name=test-kafka-connector type=kafka-cloud config:='{"topic":"foo","kafka_api_key":"foo","secret":"foo","bootstrap_server":"https://example.com"}'
Expected behavior
One of these two should have worked, or should have moved on to some other validation message.
Additional context
Documentation for the source connector shows the singular bootstrap_connector. The Python SDK uses the plural bootstrap_connectors.
コントリビューションガイド
はじめの一歩
- issue を最後まで読み、次にプロジェクトのコントリビューションガイドを読みます。
- 着手することを issue にコメントします — 二人が同じ作業をするのを防げます。
- リポジトリをフォークし、ブランチを切って変更します。
- issue 番号を参照したプルリクエストを送ります。
調査の方向性
POST /api/v1/sources/ の再現から始め、単数形と複数形のバリデーションエラーを比較してください。src/unstructured_client/models/shared/kafkacloudsourceconnectorconfiginput.py を調査し、リンク先の Kafka source connector ドキュメントと比較してください。受け付けられるフィールド名とバリデーション動作に一貫性があれば完了です。
索引モデルが issue の本文から書いたものです。
評価
- 技術スタック
- kafka, python
- 領域
- api
- issue の種類
- バグ
- 難易度
- 3/5
- 見積もり時間
- 1〜2日
- 活発さ
- 停滞
- 明瞭さ
- おおむね明確
- 初心者へのやさしさ
- 45/100