Red Hat Summit8장. Java 클라이언트에서 Kafka serializers/deserializers 구성
이 장에서는 생산자 및 소비자 Java 클라이언트 애플리케이션에서 Kafka SerDes를 구성하는 방법에 대한 자세한 정보를 제공합니다.
- 8.1절. “클라이언트 애플리케이션의 Service Registry serializer/deserializer 구성”
- 8.2절. “Service Registry serializer/deserializer 구성 속성”
- 8.3절. “다른 클라이언트 직렬화기/deserializer 유형을 구성하는 방법”
- 8.3.1절. “서비스 레지스트리를 사용하여 Avro SerDes 구성”
- 8.3.2절. “서비스 레지스트리를 사용하여 JSON Schema SerDes 구성”
- 8.3.3절. “서비스 레지스트리를 사용하여 Protobuf SerDes 구성”
사전 요구 사항
8.1. 클라이언트 애플리케이션의 Service Registry serializer/deserializer 구성
이 섹션에 표시된 예제 상수를 사용하여 클라이언트 애플리케이션에서 특정 클라이언트 serializer/deserializer(SerDe) 서비스 및 스키마 조회 전략을 직접 구성할 수 있습니다. 또는 파일 또는 인스턴스에서 해당 서비스 레지스트리 애플리케이션 속성을 구성할 수 있습니다.
다음 섹션에서는 일반적으로 사용되는 SerDe 상수 및 구성 옵션의 예를 보여줍니다.
SerDe 서비스의 구성
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 형식을 지원하고 서비스 레지스트리 SerDe 서비스와 호환되도록 ID 처리를 확장합니다. 예를 들어 기본 ID 형식을
Long에서Integer로 변경하면 Confluent ID 형식이 지원됩니다. -
Confluent ID의 처리를 단순화합니다.
true로 설정하면 글로벌 ID 조회에Integer가 사용됩니다.ID_HANDLER옵션과 함께 설정을 사용해서는 안 됩니다.
추가 리소스
- 구성 옵션에 대한 자세한 내용은 다음을 참조하십시오. 8.2절. “Service Registry serializer/deserializer 구성 속성”
SerDe 조회 전략 구성
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
...- 아티팩트 확인자 전략과 Kafka SerDe 및 아티팩트 ID 간 매핑을 구현하는 Java 클래스입니다. 기본값은 주제 ID 전략입니다. 이 클래스는 serializer 클래스에서만 사용됩니다.
-
스키마 확인자를 구현하는 Java 클래스입니다. 기본값은
DefaultSchemaResolver입니다. 이는 serializer 및 deserializer 클래스에서 사용됩니다.
추가 리소스
- 전략 검색에 대한 자세한 내용은 다음을 참조하십시오. 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 변환기와 함께 사용하는 데 필요한 직렬화기입니다.
- Service Registry Kafka 변환기와 함께 사용하는 데 필요한 역직렬러입니다.
추가 리소스
- 자세한 내용은 SerdeBasedConverter Java 클래스를 참조하십시오.
다양한 스키마 유형의 구성
다양한 스키마 기술에 대한 SerDe 구성 방법에 대한 자세한 내용은 다음을 참조하십시오.
