Java 中的 SDK Kafka - 如何正确读取 AVRO 编码的消息答案

【问题标题】：SDK Kafka in Java - How proper read an AVRO encoded messageJava 中的 SDK Kafka - 如何正确读取 AVRO 编码的消息
【发布时间】：2022-08-03 19:20:08
【问题描述】：

我正在努力寻找适当的指南或文档，说明如何从 avro json 规范广告正确生成类使用生成的类来解码来自 kafka 客户端的消息。我发现了一些使用文件数据的部分示例，但没有使用 kafka 作为源（没有模式注册表）。

我可以在某个地方找到它吗？

谢谢！

标签： java apache-kafka avro

【解决方案1】：

如果您在项目中使用 Maven 工件，则可以在 pom.xml 中使用以下插件从 .avsc 中自动生成 avro 类。

        <plugin>
            <groupId>org.apache.avro</groupId>
            <artifactId>avro-maven-plugin</artifactId>
            <version>${avro.version}</version>
            <executions>
                <execution>
                    <phase>generate-sources</phase>
                    <goals>
                        <goal>schema</goal>
                    </goals>
                    <configuration>
                        <sourceDirectory>${project.basedir}/src/main/resources/avro</sourceDirectory>
                        <outputDirectory>${project.basedir}/src/main/java/</outputDirectory>
                        <stringType>String</stringType>
                        <fieldVisibility>PRIVATE</fieldVisibility>
                    </configuration>
                </execution>
            </executions>
        </plugin>

我发现这个http://www.javawenti.com/?post=16104 是更有意义的样本，你可以试试。

How to encode/decode Kafka messages using Avro binary encoder?

【讨论】：