inflearn logo
강의

Khóa học

Chia sẻ kiến thức

Nhập môn Kafka áp dụng ngay vào thực tế

Truy vấn / Thiết lập / Thay đổi số lượng partition của một topic cụ thể

파티션 증가 질문드립니다

74

namastae1125663

24 câu hỏi đã được viết

0

안녕하세요 강사님

파티션의경우 줄일수 없다고 설명해주셨는데
만약 예로들어 실무에서 하나의 토픽 기준으로 3개의 파티션으로 작업도중 데이터 처리량이 많아져서 랙이 쌓이는걸 확인했을때

파티션을 늘리고 컨슈머도 늘린다고 가정했을때
따로 문제는없는걸까요? ( 줄이는경우에는 새로운 토픽을 생성하여 마이그레이션 한다고 설명해주셨는데 늘리는건 실제 사용중 파티션을 늘렸을때 아무런 문제가 없는지 궁금합니다 )

kafka EDA msa devops infrastructure

Câu trả lời 2

0

jscode

안녕하세요! 질문 잘 해주셨어요 !

질문해주신 내용에 대해 답변드려볼게요 ~

파티션을 늘리는 것은 실무에서 큰 문제 없이 가능합니다!

말씀해주신 상황처럼 3개 파티션에서 랙이 쌓이고 처리량이 부족해서

파티션을 늘리고 컨슈머도 함께 늘리는 건 실무에서 자주 사용하는 방법이에요 ~

 

파티션을 늘리실 때 알고계시면 좋을 점들이 몇가지 있어요 ~

[1] 운영 중인 토픽의 파티션 수를 늘리는 것은 다운타임 없이 실시간으로 안전하게 가능해요 !

[2] 기존 파티션의 데이터는 변경되지 않고, 새로운 메시지부터 새 파티션에 분산돼요 !

[3] 컨슈머 그룹의 자동 리밸런싱이 발생해서 새로운 파티션을 컨슈머들이 자동으로 할당받게 돼요 !

따라서 말씀하신 상황에서는 파티션을 늘리고 컨슈머도 추가하시면 문제없이 성능 개선이 가능합니다 :)

 

추가로 궁금하신 점 있으시면 또 질문 남겨주세요 ~

0

communityai8509

안녕하세요, 인프런 AI 인턴입니다. 나마스테님.

Kafka에서의 파티션 관리는 메시지 처리 성능과 병렬성을 결정하는데 있어서 중요한 역할을 합니다. 파티션을 증가시켜 데이터 병목을 해소하고자 할 때 몇 가지 고려해야 할 사항이 있습니다.

파티션 증가의 장점:

  1. 병렬 처리 성능 향상: 파티션 수를 늘리면 컨슈머 그룹 내 여러 인스턴스가 병렬로 메시지를 처리할 수 있어 처리 속도가 증가합니다.
  2. 확장성: 데이터량이 많아질 때, 더 많은 컨슈머들을 추가해서 시스템의 확장성을 높일 수 있습니다.

파티션 증가 시 고려사항:

  1. 데이터 재분배: 파티션을 늘리면 기존 데이터를 새로운 파티션으로 재분배해야 합니다. 때로는 이 과정에서 일부 데이터가 중복 처리되거나 순서가 달라질 수 있으므로 이에 대한 대비가 필요합니다.
  2. 컨슈머 설정: 새로운 파티션에 맞춰 컨슈머 인스턴스를 적절히 조정해야 합니다. 파티션 수에 맞게 컨슈머를 늘리면 데이터 처리에서의 효율성을 극대화할 수 있습니다.
  3. 시스템 자원: 파티션 수가 늘어나면 Kafka 브로커와 Zookeeper의 부하도 커질 수 있으므로, 시스템 자원에 맞춰 설정을 조절해야 합니다.

파티션을 늘리는 것은 일반적으로 큰 문제가 되지 않지만, 실시간 데이터 흐름을 잘 관리하기 위해서는 위의 고려사항들을 염두에 두어야 합니다.

더 깊이 있는 이해를 위해 아래 질문들을 참고하시면 좋을 것 같습니다:

저는 질문자님의 이해를 돕고자 지식공유자님의 기존 답변을 참고하여 유사한 답변 링크를 추천해드리고 있습니다.

현재 베타 기능으로 답변이 만족스럽지 않을 수 있는 점 양해 부탁드립니다. 🙏
추가적으로 궁금한 점이 있으시면, 이어서 질문해 주세요. 곧 지식공유자께서 답변해 주실 것입니다.

2. Kafka 설치 파일 다운받기 404 Not Found 오류 관련

0

55

2

UserSignedUpEventConsumer 에서 로그 DB 저장 문의

0

47

2

리더 파티션 선출 규칙에 관한 질문

0

67

2

kafka 실패 후 재시도 DLT 소비 무한으로 하는 현상이 발생합니다

1

138

2

질문드립니다.

0

52

2

잘못된 이메일 주소로 인해 발송 실패 코드

0

105

3

카프카 서버 관련 질문입니다.

0

88

2

선생님 질문이 있습니다. 왜 바로 aws 설치 하시는지 궁금합니다.

0

97

2

Kafka 음성메세지 브로커로도 적합한가요?

0

77

2

재시도조차 실패한 메시지 사후 처리하기

1

107

2

retry 시 동작과정 질문

0

116

2

JsonSerializer & JsonDeserializer

0

72

2

auto.create.topics.enable=false 설정

0

95

2

email 발송 로직 관련

0

68

2

concurrency 설정 + 같은 groupId 내에 consumer 여러개

0

74

2

concurrency 동작 안됨

0

69

3

컨슈머 서버 점진적 배포 시나리오

0

60

2

Connection -1

0

57

2

적정 파티션 개수 계산하는 방법 질문드립니다

0

126

2

섹션5 33 질문드립니다

0

43

1

aws아닌 도커로는 안되나요?

0

100

2

섹션7 51 컨슈머서버 무한 리로드?

0

140

4

섹션6 43 질문드립니다

0

53

3

kafka [37강의]

0

59

2