실제로 메시지가 중복해서 처리되는 문제가 있는데


메시지 전송 -> 브로커 저장 -> 컨슈머 소비


메시지 전송에서 인위적으로 실패시키는 시나리오 발생시키고


컨슈머에서 저장을 실패시키는 시나리오를 발생시켜야하는데


이걸 어떻게 만들어야 하나요?