Navigation :
Streaming 주요 키워드
문서 생성일: 0001-01-01 00:00:00 +0000 UTC
- Stream(스트림)
- 추가 전용 로그 파일
- 스트림에는 메시지가 저장됨
- Kafka의 Topic과 같은 것
- 스트림은 한개 이상의 Partition으로 구성
- Partition(파티션)
- Stream은 여러개의 Partition으로 분할
- 각 Partition은 여러 노드(Broker)에 위치
- Partition은 Stream을 분할하는 단위
- 여러 컨슈머는 Partition의 데이터를 읽어 병렬 처리 지원
- Cursor(커서)
- 스트림의 위치를 나타내는 지시자
- 커서는 파이텬의 특정 오프셋 및 시간으로 나타냄
- 그룹의 현재 위치 지정에도 사용
- Message(메시지)
- 스트림에 게시된(Published)된 데이터
- Base64로 인코딩 됨
- Consumer(컨슈머)
- 스트림에서 메시지를 읽어가는 객체
- 하나 이상 존재 가능
- Consumer Group(컨슈머 그룹)
- 컨슈머 그룹은 스트림에 모든 파티션으로부터 메시지 읽기 조정을 받는 인스턴스 집합
- 컨슈머 그룹의 인스턴스(컨슈머)는 Interaction을 통해서 그룹 멤버쉽을 유지
- 일정 기간 Interaction 부족할 경우에 그룹에서 인스턴스 제외
- Offset(오프셋)
- 파티션의 메시지 위치
- 스트림 읽기를 재시작할 때 offset을 지정
참조 문서
작성자: 김태완
사랑하는 민수와 데이터 관리, 데이터 분석 & 클라우드에 집중하고 있습니다.
E-mail: taewanme@gmail.com
Disclaimer
이 저작물은 Oracle과 관계없이 개인으로서 개인의 시간을 할애하여 작성된 글 입니다. 본 글의 내용, 입장, 예측은 Oracle을 공식적으로 절대 대변하지 않습니다.
