8장. Java 클라이언트에서 Kafka serializers/deserializers 구성
이 장에서는 생산자 및 소비자 Java 클라이언트 애플리케이션에서 Kafka serializers/deserializers(SerDes)를 구성하는 방법에 대한 자세한 정보를 제공합니다.
- 8.1절. “클라이언트 애플리케이션의 Service Registry serializer/deserializer 구성”
- 8.2절. “Service Registry serializer/deserializer 구성 속성”
- 8.3절. “다른 클라이언트 serializer/deserializer 유형을 구성하는 방법”
- 8.3.1절. “서비스 레지스트리를 사용하여 Avro SerDes 구성”
- 8.3.2절. “서비스 레지스트리를 사용하여 JSON 스키마 구조 구성”
- 8.3.3절. “서비스 레지스트리를 사용하여 Protobuf SerDes 구성”
사전 요구 사항
8.1. 클라이언트 애플리케이션의 Service Registry serializer/deserializer 구성
이 섹션에 표시된 예제 상수를 사용하여 클라이언트 애플리케이션에서 직접 특정 클라이언트 serializer/deserializer(SerDes) 서비스 및 스키마 조회 전략을 구성할 수 있습니다. 또는 파일 또는 인스턴스에서 해당 서비스 레지스트리 애플리케이션 속성을 구성할 수 있습니다.
다음 섹션에서는 일반적으로 사용되는 SerDes 상수 및 구성 옵션의 예를 보여줍니다.
SerDes 서비스 구성
public class SerdeConfig {
public static final String REGISTRY_URL = "apicurio.registry.url"; 1
public static final String ID_HANDLER = "apicurio.registry.id-handler"; 2
public static final String ENABLE_CONFLUENT_ID_HANDLER = "apicurio.registry.as-confluent"; 3- 서비스 레지스트리의 필수 URL입니다.
-
ID 처리를 확장하여 다른 ID 형식을 지원하고 Service Registry SerDes 서비스와 호환되도록 합니다. 예를 들어 기본 ID 형식을
Long에서Integer로 변경하면 Confluent ID 형식이 지원됩니다. -
Confluent ID의 처리를 단순화합니다.
true로 설정하면 글로벌 ID 조회에Integer가 사용됩니다. 설정을ID_HANDLER옵션과 함께 사용하면 안 됩니다.
추가 리소스
- 구성 옵션에 대한 자세한 내용은 다음을 참조하십시오. 8.2절. “Service Registry serializer/deserializer 구성 속성”
SerDes 조회 전략 구성
public class SerdeConfig {
public static final String ARTIFACT_RESOLVER_STRATEGY = "apicurio.registry.artifact-resolver-strategy"; 1
public static final String SCHEMA_RESOLVER = "apicurio.registry.schema-resolver"; 2
...추가 리소스
- 전략에 대한 자세한 내용은 다음을 참조하십시오. 7장. Java 클라이언트에서 serializers/deserializers를 사용하여 Kafka 메시지 검증
- 구성 옵션에 대한 자세한 내용은 다음을 참조하십시오. 8.2절. “Service Registry serializer/deserializer 구성 속성”
Kafka 변환기 구성
public class SerdeBasedConverter<S, T> extends SchemaResolverConfigurer<S, T> implements Converter, Closeable {
public static final String REGISTRY_CONVERTER_SERIALIZER_PARAM = "apicurio.registry.converter.serializer"; 1
public static final String REGISTRY_CONVERTER_DESERIALIZER_PARAM = "apicurio.registry.converter.deserializer"; 2- Service Registry Kafka 컨버터와 함께 사용하는 데 필요한 serializer입니다.
- Service Registry Kafka 컨버터와 함께 사용하는 데 필요한 deserialize러입니다.
추가 리소스
- 자세한 내용은 SerdeBasedConverter Java 클래스를 참조하십시오.
다양한 스키마 유형에 대한 구성
다양한 스키마 기술에 대해 SerD를 구성하는 방법에 대한 자세한 내용은 다음을 참조하십시오.
