• 채팅과 관련하여 sse 알림 설정 후 test

Error 발생

→ [Consumer clientId=consumer-notification-consumer-6, groupId=notification-consumer] Seeking to offset 19 for partition chatting-create-0

• Seek to current after exception

→ Backoff FixedBackOff{interval=0, currentAttempts=10, maxAttempts=9} exhausted for chatting-create-0@19

→ [Consumer clientId=consumer-notification-consumer-6, groupId=notification-consumer] Seeking to offset 20 for partition chatting-create-0

→ Backoff FixedBackOff{interval=0, currentAttempts=10, maxAttempts=9} exhausted for chatting-create-0@20

원인

• ListenerExecutionFailedException 오류는 리스너가 반복적으로 실패하고 있다는 의미. 기본적으로 FixedBackOff 전략을 사용하고 있는데, 이 방식은 10번의 재시도 후 더 이상 시도를 하지 않도록 설정
• Seeking to offset 19 for partition chatting-create-0:
  • Kafka consumer가 메시지를 처리하려 할 때 오프셋을 조정하려는 시도

Issue (Pm님 확인 필요)

notification.getReceiverUuidList().forEach(receiverUuid -> {
			log.info("Sending notification to user: {}", receiverUuid);
			sendFeedNotification(receiverUuid, notification); // SSE 알림 전송

			fcmTokenRepository.findByUuid(receiverUuid).get().getFcmTokenList().forEach(token -> {
				log.info("Sending push notification to user: {}", receiverUuid);
				log.info("Sending push notification to token: {}", token);
				sendPushFeedNotification(token, notification); // FCM 푸시 알림 전송
			});
		});

• 이러한 로직 처리 시 , receiverUuidList()에 대한 값들이 존재하고 그 중 하나의 receiverUuid에 대해 fcmTokenRepository.findByUuid(receiverUuid).get() 자체가 비어있는 값이라면 NoSuchException 발생 후 이것이 KafkaException이 되며 이러한 상황때문에 오프셋 크기만큼 재실행

**findByUuid(receiverUuid)**가 결과를 반환하지 않을 경우 Optional.empty() 상태에서 **get()**을 호출하면 ****NoSuchElementException****이 발생하게 됩니다. 이 예외가 메시지를 처리하지 못한 상태로 이어지며, Kafka는 메시지를 재시도 요청