stream format 관련 질문
271
58 asked
안녕하세요,
stream의 key.format, value.format 관련 질문있습니다.
이 두 옵션이 직렬화에 대한 옵션이라고 하셨는데,
select 시에는 consumer가 동작하고 insert에는 producer가 동작한다고 하셨던 것과 조금 혼동이 되어서 질문드립니다.
insert 시에 stream옵션으로 직렬화가 되면 producer의 직렬화 옵션은 어떻게 되는건가요?
그리고 select시 에는 topic 메시지를 consumer가 역직렬화해서 가져온 것을 다시 직렬화 하는건가요?
stream의 직렬화 시점에 대해 조금 이해가 되지 않습니다.
감사합니다.
Answer 1
0
안녕하십니까,
제가 질문을 제대로 이해했는지 모르겠습니다. 원하시는 답변이 아니면 다시 글 부탁드립니다.
insert시에는 stream의 key.format, value.format에 따라 메시지를 직렬화 해서 토픽에 입력합니다.
그리고 select시 에는 topic 메시지를 consumer가 해당 토픽의 key.format, value.format에 따라 역직렬화해서 출력해 줍니다.
감사합니다.
Ksqldb.io 가 confluent.io 로 리다이렉션 되요
0
49
2
복합키 디코딩 오류 질문드립니다.
0
75
2
Table의 상태(Stateful) 관리 질문
0
102
2
섹션 10 관련 강의자료
0
181
2
Compact Topic에 대하여
0
205
2
시스템 타임존과 카프카 Stream 타임존이 불일치합니다.
0
143
1
ksql DB 서버를 올릴떄 아래와 같이 에러 발생
0
147
2
스트림, 테이블 생성시 데이터 관련 문의
0
215
1
푸시 쿼리 종료 방법에 대해 문의 드립니다.
0
195
1
table의 데이터가 실시간으로 topic에 담기지 않습니다
0
226
1
debezium에서 ksqldb로
0
252
2
CLI로 실행과 코드로 실행하면 결과가 다르게 나옵니다
1
176
1
ksqldb는 workbench처럼 ui는 없을까요?
0
308
2
Pull 쿼리 제약에 대한 이유
0
218
1
IoT Event Streaming 적용에 대해서
0
210
1
[수정요청] Join이해 중 select inner join a.user_id 수정 필요
0
273
2
실무에서 카프카 환경 구축
0
531
2
[수정요청] Mview CSAS 강좌중에 Insert문장 수정 요청
0
248
1
inner join , outer join
0
199
1
group by 리파티션에 대한 질문
0
240
1
ksqldb timestamp 타입 질문
0
245
1
전통적 분석 시스템 한계에 대해 질문있습니다.
0
275
1
AWS 에서 confluent kafka 와 apache kafka 차이가 궁금 합니다.
0
1686
2
ksqlDB Cluster 여부 - 박성범님 질문(제가 대신해서 적습니다)
0
669
2