[java] Apache Avro의 스키마 레지스트리와 Java의 연동

28 Nov 2023

java

Apache Avro는 데이터 직렬화와 RPC 프레임워크를 제공하는 오픈 소스 프레임워크입니다. Avro는 간단하면서도 효율적인 데이터 교환을 위한 스키마 기반 직렬화를 가능하게 합니다. 이번 포스트에서는 Avro 스키마 레지스트리를 사용하여 Java 애플리케이션과의 연동에 대해 알아보겠습니다.

스키마 레지스트리란?

Avro 스키마 레지스트리는 Avro 스키마를 관리하고 중앙 집중화된 저장소에 스키마를 등록하는 기능을 제공합니다. 이를 통해 여러 애플리케이션에서 재사용 가능한 스키마를 공유하고, 스키마 버전 관리 및 호환성을 지원할 수 있습니다. 스키마 레지스트리는 Avro 클라이언트나 서버와 통신하여 스키마를 검색하고 등록할 수 있는 RESTful API를 제공합니다.

Apache Avro 스키마 레지스트리 연동하기

Avro 스키마 레지스트리를 Java 애플리케이션과 연동하기 위해서는 여러 단계를 거쳐야 합니다. 먼저, Maven 또는 Gradle을 사용하여 필요한 Avro 관련 종속성을 프로젝트에 추가해야 합니다.

<dependency>
    <groupId>org.apache.avro</groupId>
    <artifactId>avro</artifactId>
    <version>1.10.2</version>
</dependency>
<dependency>
    <groupId>org.apache.avro</groupId>
    <artifactId>avro-ipc</artifactId>
    <version>1.10.2</version>
</dependency>
<dependency>
    <groupId>org.apache.avro</groupId>
    <artifactId>avro-ipc</artifactId>
    <version>1.10.2</version>
</dependency>

스키마 레지스트리에 접근하여 스키마를 등록하고 검색하기 위해서는 Avro 스키마를 관리하는 API 인터페이스를 사용해야 합니다. 예를 들어, Confluent Schema Registry를 사용한다면 SchemaRegistryClient 인터페이스를 사용하여 스키마 관리 작업을 수행할 수 있습니다.

import io.confluent.kafka.schemaregistry.client.SchemaRegistryClient;
import io.confluent.kafka.schemaregistry.client.rest.RestService;

public class SchemaRegistryExample {
    public static void main(String[] args) {
        String schemaRegistryUrl = "http://localhost:8081";
        SchemaRegistryClient schemaRegistryClient = new RestService(schemaRegistryUrl);
        // 스키마 등록, 검색 등의 작업 수행
    }
}

위의 예제에서는 Confluent Schema Registry의 REST API를 사용하기 위해 RestService 클래스를 사용하였습니다. 실제 환경에서는 예제에서 사용하는 Confluent Schema Registry의 URL을 적절하게 변경해야 합니다.

위와 같이 스키마 레지스트리와 Java 애플리케이션을 연동하면 스키마의 등록, 검색 및 버전 관리 등의 기능을 활용할 수 있습니다. 이를 통해 애플리케이션 간의 데이터 교환에서 생기는 호환성 관련 문제를 해결할 수 있습니다.

스키마 레지스트리란?

Apache Avro 스키마 레지스트리 연동하기

참고 자료