Unstructured-IO / Unstructured-IO/unstructured-python-client
bug/SaaS API Kafka Cloud Connector inconsistency
Nessuno ha ancora preso questa issue.
- Lingua principale
- Python
- Stelle
- 119
- Fork
- 22
- Merge medio
- 1g 21h
- PR unite (30g)
- 1
Descrizione
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.
Guida per i contributori
Apri la guida per i contributori
Come iniziare
- Leggi tutta la issue e poi la guida ai contributi del progetto.
- Commenta sulla issue per dire che te ne occupi tu — evita che due persone facciano lo stesso lavoro.
- Fai un fork del repository e lavora su un branch.
- Apri una pull request che faccia riferimento al numero della issue.
Direzione di ricerca
Inizia riproducendo POST /api/v1/sources/ e confronta i relativi errori di validazione al singolare e al plurale. Ispeziona src/unstructured_client/models/shared/kafkacloudsourceconnectorconfiginput.py e confrontalo con la documentazione collegata del Kafka source connector; il lavoro è terminato quando il nome del campo accettato e il comportamento di validazione sono coerenti.
Scritto dal modello di indicizzazione a partire dal testo della issue.
Valutazione
- Stack tecnologico
- kafka, python
- Ambito
- api
- Tipo di issue
- Bug
- Difficoltà
- 3/5
- Tempo stimato
- 1-2 giorni
- Stato di attività
- Ferma
- Chiarezza
- Abbastanza chiara
- Idoneità per principianti
- 45/100