import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.dataformat.avro.AvroMapper;
import com.fasterxml.jackson.dataformat.avro.schema.AvroSchema;
public class User {
private String name;
private int age;
// getters and setters
public static void main(String[] args) throws Exception {
User user = new User();
user.setName("John Doe");
user.setAge(30);
AvroMapper avroMapper = new AvroMapper();
AvroSchema schema = avroMapper.schemaFor(User.class);
ObjectMapper objectMapper = new ObjectMapper();
byte[] avroData = objectMapper
.writer(schema)
.writeValueAsBytes(user);
User newUser = objectMapper.readerFor(User.class)
.with(schema)
.readValue(avroData);
System.out.println(newUser.getName());
System.out.println(newUser.getAge());
}
}
