<dependency>

    <groupId>org.apache.avro</groupId>

    <artifactId>avro</artifactId>

    <version>1.7.7</version>

</dependency>

<build>

    <plugins>

        <plugin>

            <groupId>org.apache.avro</groupId>

            <artifactId>avro-maven-plugin</artifactId>

            <version>1.7.7</version>

            <executions>

                <execution>

                    <phase>generate-sources</phase>

                    <goals>

                        <goal>schema</goal>

                        <goal>protocol</goal>

                        <goal>idl-protocol</goal>

                    </goals>

                    <configuration>

                        <!-- 源目录，用于存放 avro的schema文件及protocol文件 ,如果没加如下配置，那么默认从/src/main/avro下面找avsc文件，生成的java文件放到target/generated-sources/avro下面-->

                        <sourceDirectory> ${project.basedir}/src/main/avro/</sourceDirectory>

                        <outputDirectory> ${project.basedir}/src/main/java/</outputDirectory>

                    </configuration>

                </execution>

            </executions>

        </plugin>

        <plugin>

            <groupId>org.apache.maven.plugins</groupId>

            <artifactId>maven-compiler-plugin</artifactId>

            <configuration>

                <source>1.7</source>

                <target>1.7</target>

            </configuration>

        </plugin>

    </plugins>

</build>

public class Test_avro {

    public static void main(String[] args) throws IOException {

        //TODO 序列化操作

        product pro = product.newBuilder().build();

        pro.setProductId("1");

        pro.setCompanyName("这是一个测试");

        pro.setProductInfo("测试的详细说明");

        pro.setDirection("1");

        //将生成的数据保存到本地文件中

        File file = new File("/Users/niutao/Desktop/avro_test/user.avro");

        DatumWriter<product> productDatumWriter = new SpecificDatumWriter<product>(product.class);

        DataFileWriter<product> dataFileWriter = new DataFileWriter<product>(productDatumWriter);

        dataFileWriter.create(product.getClassSchema() , file);

        dataFileWriter.append(pro);

        dataFileWriter.close();

        //TODO 反序列

        DatumReader<product> productDatumReader = new SpecificDatumReader<product>(product.class);

        DataFileReader<product> productDataFileReader = new DataFileReader<product>(file , productDatumReader);

        product pro_reader = null;

        while (productDataFileReader.hasNext()){

            pro_reader = productDataFileReader.next();

            System.out.println(pro_reader);

        }

    }

}