DB/Kafka
-
[KAFKA] CommitFailedExceptionDB/Kafka 2022. 12. 28. 16:10
카프카 오류 Synchronous auto-commit of offsets {topic-2=OffsetAndMetadata{offset=96, leaderEpoch=0, metadata=''}} failed: Offset commit cannot be completed since the consumer is not part of an active group for auto partition assignment; it is likely that the consumer was kicked out of the group. 위와 같은 오류가 발생해서 찾아보니 다음과 같다. Kafka에서 CommitFailedException이 나오는 유형은 아래와 같다. consumer 로직의 처리시간이 max.poll.int..
-
[KAFKA] 카프카 producer configurationDB/Kafka 2022. 7. 20. 19:28
acks 란 acks는 acknowledgments의 약자로 사전에서 찾아 보면 "승인", 확인 프로듀서가 메시지를 보내고 그 메시지를 카프카가 잘 받았는지 확인을 할 것인지 또는 확인을 하지 않을 것인지를 결정하는 옵션 acks 옵션 OPTION 손실율 속도 DESCRIPTION acks = 0 상 상 프로듀서는 자신이 보낸 메시지에 대해 카프카로부터 확인을 기다리지 않는다. acks = 1 중 중 프로듀서는 자신이 보낸 메시지에 대해 카프카의 leader가 메시지를 받았는지 기다립니다. follower들은 확인하지 않습니다. leader가 확인응답을 보내고, follower에게 복제가 되기 전에 leader가 fail되면, 해당 메시지는 손실될 수 있다. acks = all(-1) 하 하 프로듀서는 ..