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

Question

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

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

Answer 1

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

Обычно я делаю это для выдачи данных в 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
            }
        }           
    ]
}'