Spring 합치도 스키마 비 직렬화 예제

Question

spring-kafka 2.0.0.Release를 사용하고 컨플릭트 스키마 레지스트리를 메시지를 비 직렬화하는 소스로 사용하는 소비자를 만들었습니까? 그렇다면 예제를 가르쳐 주시겠습니까?

내가 해결하려고하는 문제는 MFC에서 발생하는 이벤트를 스트림하는 kafka 연결 플랫폼에 Debezium CDC 커넥터가 있다는 것입니다. 이러한 이벤트를 변환하고 다시 스트림해야합니다. 이벤트를 이해하려면 페이로드를 deserialize해야합니다. 나는이 단계에서 현재 붙어있다.

Answer 1

Sastry

이 문제는 while back를 해결하기 위해 나타납니다, 그래서 나는 다음과 같은 테스트 코드는 카프카의 스키마 레지스트리를 구성 할 수 있습니다 특정 part in it을 지적하고 싶습니다. 명확한 지 또는 더 많은 도움이 필요한지 살펴보십시오.