Я использую приведенное ниже определение в своей схеме AVRO, зарегистрированной в теме Kafka
{
"doc": "list of employees",
"name": "employees",
"type": [
"null",
{
"type": "array",
"items": {
"avro.java.string": "String",
"type": "string"
}
}
],
"default": null
}
Ожидаемый результат:
"сотрудники": ["Аджай", "Виджай"] ИЛИ ноль
Но ниже единицы:
"employees": {
"array": [
"Ajay", "Vijay"
]
}
Я проверил, используя приведенную ниже схему, она работает нормально. если я добавляю значение по умолчанию, то создается дополнительное поле массива
{
"doc": "list of employees",
"name": "employees",
"type":
{
"type": "array",
"items": {
"avro.java.string": "String",
"type": "string"
}
}
}
Подробнее здесь: https://stackoverflow.com/questions/791 ... afka-topic
Проблема Avro Schema, возникающая при отправке в слитную тему Kafka ⇐ JAVA
-
- Похожие темы
- Ответы
- Просмотры
- Последнее сообщение
-
-
Spring Boot Embedded Kafka для создания событий с использованием Avro Schema
Anonymous » » в форуме JAVA - 0 Ответы
- 44 Просмотры
-
Последнее сообщение Anonymous
-
-
-
Не удалось найти Cluentent Kafka Avro Serializer & Schema Registry Client в Maven
Anonymous » » в форуме JAVA - 0 Ответы
- 18 Просмотры
-
Последнее сообщение Anonymous
-
-
-
Не удалось найти Cluentent Kafka Avro Serializer & Schema Registry Client в Maven
Anonymous » » в форуме JAVA - 0 Ответы
- 12 Просмотры
-
Последнее сообщение Anonymous
-
-
-
Не удалось найти Cluentent Kafka Avro Serializer & Schema Registry Client в Maven
Anonymous » » в форуме JAVA - 0 Ответы
- 9 Просмотры
-
Последнее сообщение Anonymous
-