Публикация avro сериализованных данных с использованием прокси kafka-rest - PullRequest
Новая
       21

Публикация avro сериализованных данных с использованием прокси kafka-rest

0 голосов
/ 08 февраля 2019

Я пытаюсь опубликовать некоторые данные по теме kafka, для которой схема avro данных содержит типы объединения. Я использую прокси-компонент kafka-rest на Android для создания сообщений.

Учитывая, что данные содержат объединениеtype: ни один из преобразователей pojo в json не работает.

1 Ответ

0 голосов
/ 08 февраля 2019

Пожалуйста, поделитесь своими почтовыми данными.

Обычно я делаю это для передачи данных в Kafka Avro через REST.

1) Если у вас нет идентификатора схемы:

curl --request POST \
      --url http://MYKAFKARESTAPI/topics/MYTOPICNAME \
      --header 'accept: application/vnd.kafka.v2+json' \
      --header 'content-type: application/vnd.kafka.avro.v2+json' \
      --data '{
    "value_schema": "{\"type\": \"record\", \"name\": \"User\", \"fields\": [{\"name\": \"name\", \"type\": \"string\"},{\"name\": \"age\", \"type\": \"int\"}]}",
    "records": [
        {
            "value": {
                "name": "Maria",
                "age": 10
            }
        },
        {
            "value": {
                "name": "Jorge",
                "age": 11
            }
        }   
    ]
}'

Если у вас уже есть идентификатор схемы: 

curl --request POST \
  --url http://MYKAFKARESTAPI/topics/MYTOPICNAME \
  --header 'accept: application/vnd.kafka.v2+json' \
  --header 'content-type: application/vnd.kafka.avro.v2+json' \
  --data '{
    "value_schema_id": 24,
    "records": [
        {
            "value": {
                "name": "Maria",
                "age": 10
            }
        },
        {
            "value": {
                "name": "Jorge",
                "age": 11
            }
        }           
    ]
}'
...