Skip to content

Commit

Permalink
docs: πŸ“ [Chapter 07] μ‹ λ’°μ„± μžˆλŠ” 데이터 전달 (μž₯애상황 μ‹œλ‚˜λ¦¬μ˜€)
Browse files Browse the repository at this point in the history
  • Loading branch information
Shinminjin committed Jan 5, 2025
1 parent b1d148b commit ca849f7
Showing 1 changed file with 12 additions and 8 deletions.
20 changes: 12 additions & 8 deletions _posts/kafka/2025-01-04-chapter07.md
Original file line number Diff line number Diff line change
Expand Up @@ -22,15 +22,15 @@ tags: [μΉ΄ν”„μΉ΄ ν•΅μ‹¬κ°€μ΄λ“œ]

## **3. μ‹œλ‚˜λ¦¬μ˜€2: μΉ΄ν”„μΉ΄ 브둜컀1(`kafka-docker-kafka-1`) μž₯μ•  λ°œμƒ 🚫**

1. `localhost:9092`μ—μ„œ μ‹€ν–‰ 쀑인 `kafka-docker-kafka-1` μ»¨ν…Œμ΄λ„ˆκ°€ μž₯μ• λ₯Ό λ°œμƒμ‹œν‚€κ±°λ‚˜ μ’…λ£Œλ¨
1. `localhost:9092`μ—μ„œ μ‹€ν–‰ 쀑인 `kafka-docker-kafka-1` μ»¨ν…Œμ΄λ„ˆκ°€ μž₯μ• κ°€ λ°œμƒν•˜κ±°λ‚˜ μ’…λ£Œλ¨
2. ν”„λ‘œλ“€μ„œμ™€ μ»¨μŠˆλ¨ΈλŠ” μ—¬μ „νžˆ `localhost:9093` λΈŒλ‘œμ»€μ— μ—°κ²°ν•˜μ—¬ λ©”μ‹œμ§€λ₯Ό 주고받을 수 있음
3. 메타데이터 갱신이 이루어져 ν΄λΌμ΄μ–ΈνŠΈλŠ” μƒˆλ‘œμš΄ 브둜컀 정보λ₯Ό μΈμ‹ν•˜κ³ , μž₯μ• κ°€ λ°œμƒν•œ 브둜컀λ₯Ό μ œμ™Έν•œ μƒνƒœμ—μ„œ μ •μƒμ μœΌλ‘œ μž‘μ—…μ„ 계속할 수 있음
4. μΉ΄ν”„μΉ΄ ν΄λŸ¬μŠ€ν„°λŠ” μž₯μ• κ°€ λ°œμƒν•œ 브둜컀의 νŒŒν‹°μ…˜ 리더λ₯Ό `localhost:9093`에 μžˆλŠ” 브둜컀둜 μ „ν™˜ν•¨
5. 이둜써 ν΄λŸ¬μŠ€ν„°λŠ” μž₯μ•  λ°œμƒ 후에도 μ •μƒμ μœΌλ‘œ λ©”μ‹œμ§€λ₯Ό μ²˜λ¦¬ν•  수 있음

## **4. μ‹œλ‚˜λ¦¬μ˜€ 3: μΉ΄ν”„μΉ΄ 브둜컀 1 볡ꡬ πŸ”„**

1. `localhost:9092`μ—μ„œ μ‹€ν–‰ 쀑인 `kafka-docker-kafka-1` μ»¨ν…Œμ΄λ„ˆκ°€ λ³΅κ΅¬λ˜κ±°λ‚˜ μž¬μ‹œμž‘λ¨
1. `localhost:9092`μ—μ„œ μ‹€ν–‰ 쀑인 `kafka-docker-kafka-1` μ»¨ν…Œμ΄λ„ˆκ°€ λ³΅κ΅¬λ˜κ±°λ‚˜ λ‹€μ‹œ μ‹œμž‘λ¨
2. ν΄λΌμ΄μ–ΈνŠΈλŠ” `localhost:9092` 브둜컀λ₯Ό λ‹€μ‹œ μ‚¬μš©ν•  수 있게 되며, λ©”μ‹œμ§€ 전솑과 μˆ˜μ‹ μ΄ μ •μƒμ μœΌλ‘œ 이루어짐
3. 볡ꡬ된 λΈŒλ‘œμ»€λŠ” μΉ΄ν”„μΉ΄ ν΄λŸ¬μŠ€ν„°μ˜ μΌλΆ€λ‘œ μžλ™μœΌλ‘œ λ‹€μ‹œ 참여함

Expand Down Expand Up @@ -309,12 +309,13 @@ spring:
**κΈ°λŒ€μ™€ λ‹€λ₯Έ κ²°κ³Όκ°€ λ°œμƒν•œ 원인 뢄석 (μΆ”μΈ‘ πŸ€”)**

- **메타데이터 κ°±μ‹  지연**
- ν΄λΌμ΄μ–ΈνŠΈκ°€ μž₯μ•  브둜컀(`localhost:9092`)λ₯Ό κ°μ§€ν•˜κ³  λ‹€λ₯Έ 브둜컀(`localhost:9093`)둜 μ „ν™˜ν•˜λ €λ©΄ 메타데이터가 μ΅œμ‹  μƒνƒœμ—¬μ•Ό ν•˜μ§€λ§Œ, 갱신이 μ§€μ—°λ˜μ–΄ μ „ν™˜ μ‹€νŒ¨
- 메타데이터 κ°±μ‹  μ£ΌκΈ°κ°€ λ„ˆλ¬΄ κΈΈκ±°λ‚˜, κ°±μ‹  μš”μ²­μ΄ μž₯μ• λ‘œ 인해 μ²˜λ¦¬λ˜μ§€ μ•Šμ•˜μ„ κ°€λŠ₯μ„±
- ν΄λΌμ΄μ–ΈνŠΈκ°€ μž₯μ•  브둜컀λ₯Ό κ°μ§€ν•œ ν›„ λ‹€λ₯Έ 브둜컀둜 μ „ν™˜ν•˜λ €λ©΄ μ΅œμ‹  메타데이터가 ν•„μš”ν•¨
- μž₯μ• λ‘œ 인해 메타데이터 κ°±μ‹  μš”μ²­μ΄ μ²˜λ¦¬λ˜μ§€ μ•Šμ•˜μ„ μˆ˜λ„ 있음

- **νŒŒν‹°μ…˜ 리더 μ „ν™˜ μ‹€νŒ¨**
- `localhost:9093`이 μƒˆλ‘œμš΄ νŒŒν‹°μ…˜ λ¦¬λ”λ‘œ μ „ν™˜λ˜μ§€ μ•Šμ•˜κ±°λ‚˜, ν΄λΌμ΄μ–ΈνŠΈκ°€ μƒˆλ‘œμš΄ 리더 정보λ₯Ό 받지 λͺ»ν•΄ λ©”μ‹œμ§€ 전솑 μ‹€νŒ¨
- μ΄λŠ” ν΄λŸ¬μŠ€ν„° λ‚΄λΆ€μ˜ 리더 μ„ μΆœ 지연 λ˜λŠ” ν΄λΌμ΄μ–ΈνŠΈ 메타데이터 κ°±μ‹  μ‹€νŒ¨ λ•Œλ¬ΈμΌ κ°€λŠ₯μ„±
- `localhost:9093`이 μƒˆλ‘œμš΄ νŒŒν‹°μ…˜ λ¦¬λ”λ‘œ μ „ν™˜λ˜μ§€ μ•Šμ•˜μ„ κ°€λŠ₯성이 있음
- ν΄λΌμ΄μ–ΈνŠΈκ°€ μƒˆλ‘œμš΄ 리더 정보λ₯Ό 받지 λͺ»ν•΄ λ©”μ‹œμ§€ 전솑에 μ‹€νŒ¨ν–ˆμ„ 수 있음
- μ΄λŠ” ν΄λŸ¬μŠ€ν„° λ‚΄λΆ€μ˜ 리더 μ„ μΆœ 지연 λ˜λŠ” ν΄λΌμ΄μ–ΈνŠΈ 메타데이터 κ°±μ‹  μ‹€νŒ¨ λ•Œλ¬ΈμΌ κ°€λŠ₯μ„± 있음


## **8. μ‹œλ‚˜λ¦¬μ˜€3 μ‹€ν–‰ - μΉ΄ν”„μΉ΄ 브둜컀1 볡ꡬ πŸ”§**
Expand Down Expand Up @@ -466,9 +467,12 @@ Disconnecting from node 0 due to request timeout
request.timeout.ms: 600000
```

**μ˜ˆμƒκ²°κ³Ό** : 브둜컀의 응닡 지연이 60초 이내일 경우 νƒ€μž„μ•„μ›ƒ 였λ₯˜κ°€ λ°œμƒν•˜μ§€ μ•ŠμŒ
**μ˜ˆμƒκ²°κ³Ό**
- λ„€νŠΈμ›Œν¬ 지연이 30초라고 κ°€μ •ν•˜κ³  브둜컀의 응닡 지연 μž„κ³„κ°’μ„ 60초둜 μ„€μ •ν–ˆμŒ
- νƒ€μž„μ•„μ›ƒ 였λ₯˜ λ°œμƒμ•ˆν•˜μ§€ μ•Šμ„κΉŒ..?

**[μ‹€νŒ¨] νƒ€μž„μ•„μ›ƒ 였λ₯˜ λ°œμƒ** β†’ μ΄λ‘ μ μœΌλ‘œλŠ” 될 것 κ°™μ•˜λŠ”λ°.. μ•ˆλœλ‹€
**κΈ°λŒ€μ™€ λ‹€λ₯Έ κ²°κ³Ό**
- νƒ€μž„μ•„μ›ƒ 였λ₯˜ λ°œμƒ

```bash
org.apache.kafka.common.errors.DisconnectException: null
Expand Down

0 comments on commit ca849f7

Please sign in to comment.