Kafka REST Proxy HTTP 415 Неподдерживаемый тип носителя, когда я публикую данные в теме - PullRequest
Новая
       48

Kafka REST Proxy HTTP 415 Неподдерживаемый тип носителя, когда я публикую данные в теме

0 голосов
/ 09 января 2020

Я сталкиваюсь с HTTP 415 Неподдерживаемый ответ Media Type от Kafka REST Proxy всякий раз, когда я пытаюсь создать записи для topi c, имя которых test2

Это моя деталь value_schema в моей schema_registry 

{'subject': 'test2-value', 'version': 1, 'id': 2, 'schema': '{"type":"record","name":"root","namespace":"orderbook","fields":[{"name":"type","type":"string"},{"name":"product_id","type":"int"},{"name":"payload","type":{"type":"array","items":{"type":"map","values":"long"}}}]}'}

и у меня нет key_schema в schema_registry, я просто написал value_schema в schema_registry, как это enter image description here Q1. Должен ли я сделать key_registry для создания записей с использованием REST?

Это то, что я пытался. Использование скрипта python для отправки запроса на REST-прокси и получение ответа 415. 

import requests

url = "http://localhost:8082/topics/test2"
payload = '''
{
    "key_schema_id": null,
    "value_schema_id": 1,
    "records": [{
        "value": {
            "type": "buyer",
            "product_id": 1,
            "payload": [
                "price": 1,
                "volume": 2
            ]
        }
    }]
}
'''

headers = {"Content-Type": "application/vnd.schemaregistry.v2+json", "Accept": "application/vnd.kafka.v2+json, application/vnd.kafka+json, application/json"}
r = requests.post(url, headers=headers, data=payload)
# if r.status_code == requests.codes.ok:
print(r.json())

Q2. это неправильная структура с моей value_schema? Что я должен делать для использования REST Proxy?

...