홈>
kafka-jms-client를 사용하여 현재 jms 브로커를 교체하고 싶습니다. 문서 에 따르면 일부 기능은 지원되지 않습니다 커밋 또는 롤백과 같은 클라이언트가 커밋 또는 롤백을 호출하면 어떻게됩니까? API가 단순히 응답하지만 실제로 Kafka 측에서 아무것도하지 않습니까?
- 답변 # 1
트렌드
- OpenCv의 폴더에서 여러 이미지 읽기 (python)
- 파이썬 셀레늄 모든 "href"속성 가져 오기
- html - 자바 스크립트 - 클릭 후 변경 버튼 텍스트 변경
- javascript - 현재 URL에서 특정 div 만 새로 고침/새로 고침
- JSP에 대한 클래스를 컴파일 할 수 없습니다
- JavaScript 변수를 HTML div에 '출력'하는 방법
- git commit - 자식 - 로컬 커밋 된 파일에 대한 변경을 취소하는 방법
- jquery - JavaScript로 현재 세션 값을 얻으시겠습니까?
- javascript - swiperjs에서 정지, 재생 버튼 추가
- python - 화면에서 찾은 요소를 찾을 수없는 경우 셀레늄
소스 코드를 들여다 보면 구현이 모두
다음은javax.jms.Session.commit()임을 알 수있다 그리고javax.jms.Session.rollback()Kafka JMS 클라이언트의 경우 아무 것도 수행하지 않습니다.rollback()에 대한 구현입니다. 여기commit()에 대한 구현이 있습니다. (commit()를 호출합니다.KafkaMessageConsumer에서 ). 보시다시피 두 방법 모두 궁극적으로 아무것도하지 않습니다. 마치 모든 것이 작동하는 것처럼 돌아옵니다.javax.jms.Session에 대한 다른 방법의 많은 구현도 이와 동일한 패턴을 따릅니다.