heartbeat에 관하여 질문이 있습니다.
255
작성한 질문수 5
강사님 heartbeat관련 문제를
poll 사이즈를 늘려도 해결이 안되는데 보통 어떤 상황에 맞게 어떻게 설정하여 해결을 하나요?
지금 전 aiokafka를 사용중입니다
답변 2
0
안녕하세요.
카프카 공식 자바 클라이언트가 아닌 써드 파티 클라이언트의 이슈는 해당 라이브러리 배포자에게 문의하시는 것이 좋습니다.
aiokafka issue 등록 : https://github.com/aio-libs/aiokafka/issues
0
안녕하세요 ttaein 님, 인프런 AI 인턴이에요.
heartbeat와 관련된 문제를 해결하기 위해 poll 사이즈를 늘렸음에도 불구하고 문제가 해결되지 않는다면, 일반적으로 다음과 같은 상황에 대해 설정을 확인해 볼 수 있습니다:
1. Kafka Broker의 설정: Kafka Broker의 heartbeat 관련 설정을 확인해보세요. 이 설정이 클라이언트의 heartbeat을 처리할 충분한 여유 시간을 제공하는지 확인해야 합니다.
2. 네트워크 문제: 클라이언트와 Kafka Broker 사이에 네트워크 문제가 있는지 확인해보세요. 네트워크 지연이나 패킷 손실로 인해 heartbeat 응답이 늦어지거나 도달하지 않을 수 있습니다.
3. 클라이언트 설정: 클라이언트의 heartbeat 관련 설정을 살펴보세요. 필요한 경우 클라이언트의 heartbeat 인터벌을 조정하거나, heartbeat 재시도 횟수를 조정하여 문제를 해결할 수 있을 수 있습니다.
위의 설정을 확인하고 조정하여도 문제가 해결되지 않는다면, 더 자세한 상황과 에러 메시지를 함께 확인해야 정확한 도움을 드릴 수 있습니다. 감사합니다!
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
78
2
auto.commit.interval.ms 옵션 관련 질문 드립니다.
0
141
2
파티션, 컨슈머 그룹, 컨슈머 관련 질문
0
117
1
java, kotlin
0
130
2
shutdownThread 에 대한 문의 입니다.
0
154
2
zookeeper실행시 오류가 발생합니다.
0
268
2
커스텀 소스 커넥터에서 Thread.sleep (1000) 은 왜 하는거에요?
0
152
2
처리량을 늘리기 위해서 파티션을 늘리고 컨슈머를 늘려야한다고 설명하셨는데요
0
180
3
파티션 개수와 컨슈머 개수의 처리량 관련 질문
0
163
2
동영상 및 이미지 처리 관련 문의 드립니다.
0
225
2
주키퍼 없이 사용 문의 드립니다.
0
302
1
kafka 를 띄우니 오류가 발생하고 종료합니다.
0
280
3
zookeeper 실행시 오류 .. 무엇을 해야 할까요?
0
220
2
파티션 추가로 해결할 수 있지만 늘어난 파티션은 줄일 수 없지 않나요?
0
192
2