컨슈머 --partition 옵션
294
작성한 질문수 58
producer와 consumer는 리더 파티션과 통신해야한다고 알고 있었는데요, --partition 옵션으로 지정하는 파티션이 리더 파티션이 아닌 경우에도 메시지를 소비하는 것이 가능한것인가요?
답변 1
0
안녕하세요. kafka-console-consumer.sh를 사용하실 때 --partition 명령어를 함께 사용하시면 특정 파티션의 데이터만 가져올 수 있습니다. kafka-console-consumer.sh 사용시 --partition 명령어 사용 여부와 관계 없이 기본적으로 토픽의 리더 파티션과 통신한다고 생각하시면 좋습니다.
0
그렇다면 --partition으로 지정하는 파티션이 리더 파티션인 경우 해당 파티션의 데이터를 가져오는 것이고 리더 파티션이 아닌 파티션을 지정한 경우 옵션을 무시하고 리더 파티션과 통신하는건가요?
0
쉽게 생각해서 프로듀서나 컨슈머가 통신하는 토픽의 파티션은 리더 파티션이라고 보시면 됩니다. 즉, --partition n 으로 설정한다면 n번 리더 파티션과 통신하는 것입니다.
consume 이후 lag가 줄어들지 않음
0
74
2
안녕하세요. 강의의 카프카 버전과 현재 시점의 카프카의 차이점 문의 드립니다.
0
112
2
멱등성 프로듀서 retries 관련 질문입니다.
0
97
2
채팅 서비스 개발 시 주의점이 있을까요?
0
98
2
충분히 큰 파티션 생성시 궁금증이 존재합니다.
0
86
2
KTable 키가 없는 레코드 처리
0
72
2
컨슈머 테스트 코드 작성
0
94
2
리밸런스 onPartitionRevoked이 필요한 상황
0
74
2
카프카 클러스터에서 감당 가능한 파티션(레플리카) 수 문의
0
119
2
reset offset 질문
0
77
2
KStreamJoinKTable 실행시 오류
0
77
2
auto.commit.interval.ms 옵션 관련 질문 드립니다.
0
141
2
파티션, 컨슈머 그룹, 컨슈머 관련 질문
0
117
1
java, kotlin
0
130
2
shutdownThread 에 대한 문의 입니다.
0
153
2
zookeeper실행시 오류가 발생합니다.
0
267
2
커스텀 소스 커넥터에서 Thread.sleep (1000) 은 왜 하는거에요?
0
152
2
처리량을 늘리기 위해서 파티션을 늘리고 컨슈머를 늘려야한다고 설명하셨는데요
0
180
3
파티션 개수와 컨슈머 개수의 처리량 관련 질문
0
163
2
동영상 및 이미지 처리 관련 문의 드립니다.
0
224
2
주키퍼 없이 사용 문의 드립니다.
0
302
1
kafka 를 띄우니 오류가 발생하고 종료합니다.
0
279
3
zookeeper 실행시 오류 .. 무엇을 해야 할까요?
0
220
2
파티션 추가로 해결할 수 있지만 늘어난 파티션은 줄일 수 없지 않나요?
0
192
2