7.5. Kafka 생산자 클라이언트의 스키마 사용

프로세스

1. 서비스 레지스트리의 URL을 사용하여 클라이언트를 구성합니다. 예를 들면 다음과 같습니다.

   String registryUrl = "https://registry.example.com/apis/registry/v2";
   Properties props = new Properties();
   props.putIfAbsent(SerdeConfig.REGISTRY_URL, registryUrl);

   Copy to Clipboard Toggle word wrap

2. serializer를 사용하여 클라이언트를 구성하고 서비스 레지스트리에서 스키마를 조회하도록 전략을 구성합니다. 예를 들면 다음과 같습니다.

   props.put(CommonClientConfigs.BOOTSTRAP_SERVERS_CONFIG, "my-cluster-kafka-bootstrap:9092");
   props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, AvroKafkaSerializer.class.getName()); 

   1

   
   props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, AvroKafkaSerializer.class.getName()); 

   2

   
   props.put(SerdeConfig.FIND_LATEST_ARTIFACT, Boolean.TRUE); 

   3

   Copy to Clipboard Toggle word wrap

   1

   서비스 레지스트리에서 제공하는 메시지 키의 serializer입니다.

   2

   서비스 레지스트리에서 제공하는 메시지 값의 serializer입니다.

   3

   스키마의 글로벌 ID를 찾는 조회 전략입니다.