우리는 io.confluent.connect.sftp.SftpCsvSourceConnectorsftp 위치에서 csv 파일을 읽고 메시지를 kafka로 푸시하는 데 사용합니다 ....하지만 kafka 주제의 메시지는 csv (문자열, 쉼표로 구분)로 오지 않지만 특정 키-값 형식의 comme Struct : ex Struct {branchBaseCurrCode = EUR, 국가 = CA} ...
나는 Kafka-Streams를 사용한다 .... 이것을 어떻게 deserialize합니까? 어떤 구성을 사용해야합니까? 어떤 Java 객체로 deserialize합니까? 내 속성이 스키마와 정확히 동일하다는 것을 알고 내 POJO로 직접 역 직렬화 할 수 있습니까?
대신에 SftpCsvSourceConnector직접 쓸 수 있습니까 ?jsonStruct
ConverterAvro, Protobuf 등과 같은 적절한을 사용하도록 커넥터를 구성합니다 . 원하는 경우 일반 JSON을 사용할 수도 있습니다.
예 :
"value.converter":"org.apache.kafka.connect.json.JsonConverter",
참조 https://www.confluent.io/blog/kafka-connect-deep-dive-converters-serialization-explained를
이 기사는 인터넷에서 수집됩니다. 재 인쇄 할 때 출처를 알려주십시오.
침해가 발생한 경우 연락 주시기 바랍니다[email protected] 삭제
몇 마디 만하겠습니다