12 days of Apache Kafka - 10. Schema Registry

www.youtube.com/watch?v=_x9RacHDQY0

카프카를 많이 이용하다보면 2가지 상황이 생긴다.

1. 새로운 컨슈머가 존재하는 토픽을 쓰고 싶은 경우 (토픽의 메세지 form 에 대해 알고 있어야 한다. )
2. 토픽 스키마를 변경하고 싶은 경우 

 

→ 스키마 레지스트리가 위의 문제를 해결해준다.

Schema Registry

stand-alone, 스키마들을 저장하고 있다. 저장하고 캐쉬도 하고 있다. 
클러스터로 관리할 수 있다. API 로 되어 있고 , consumer/ producer 시 이전 버전과의 비교를 한다. 

produce 타이밍에 스키마를 받아서 맞는 스키마에 맞게 데이터를 만든다.룰을 정하고 그 룰에 맞게 변화하면 성공하고, 룰에 맞지 않으면 실패하게 한다. 
consume 시엔 스키마에 맞지 않으면 컨슈밍하지 않는다. 

JSON, Avro , Protocol Buffers 세 가지 format 으로 다룰 수 있다. 
스키마에 변화를 주고 싶다면, 위 format 으로 입력한 값들을 변경해주면 된다.