use*_*148 3 json avro apache-kafka
有一个相当复杂的Avro模式(我无法修改)。
尝试在Java中模拟JSON示例:
GenericRecord genericRecord = AvroUtil.jsonToGenericRecord(jsonData, avroSchema);
Run Code Online (Sandbox Code Playgroud)
它不断失败:
Exception in thread "main" org.apache.avro.AvroTypeException: Expected start-union. Got VALUE_STRING
Run Code Online (Sandbox Code Playgroud)
是否存在例如在线工具,它将为任何给定的Avro模式提供JSON数据示例?(以便它可以正确匹配)
尝试模拟JSON数据数小时,但仍然没有成功。
您可以使用trevni依赖性和测试范围来创建随机数据。这里有一个示例代码
import org.apache.avro.Schema;
import org.apache.trevni.avro.RandomData;
import java.util.Iterator;
public class JSONExample {
public static void main(String [] args){
Schema schema = new Schema.Parser().parse("{\n" +
" \"type\": \"record\",\n" +
" \"namespace\": \"com.acme\",\n" +
" \"name\": \"Test\",\n" +
" \"fields\": [\n" +
" { \"name\": \"name\", \"type\": \"string\" },\n" +
" { \"name\": \"age\", \"type\": \"int\" },\n" +
" { \"name\": \"sex\", \"type\": \"string\" },\n" +
" { \"name\": \"active\", \"type\": \"boolean\" }\n" +
" ]\n" +
"}");
Iterator<Object> it = new RandomData(schema, 1).iterator();
System.out.println(it.next());
}
}
Run Code Online (Sandbox Code Playgroud)
输出
{"name": "cjnyvbmetf", "age": -1757126879, "sex": "", "active": false}
Run Code Online (Sandbox Code Playgroud)
Maven依赖
<dependencies>
<dependency>
<groupId>org.apache.avro</groupId>
<artifactId>avro</artifactId>
<version>1.8.2</version>
</dependency>
<dependency>
<groupId>org.apache.avro</groupId>
<artifactId>trevni-core</artifactId>
<classifier>tests</classifier>
<version>1.8.2</version>
</dependency>
<dependency>
<groupId>org.apache.avro</groupId>
<artifactId>trevni-avro</artifactId>
<classifier>tests</classifier>
<version>1.8.2</version>
</dependency>
</dependencies>
Run Code Online (Sandbox Code Playgroud)
| 归档时间: |
|
| 查看次数: |
3066 次 |
| 最近记录: |