https://kafka.apache.org/25/javadoc/index.html?org/apache/kafka/clients에 설명 된대로 Spring Kafka를 사용하여 이벤트를 로컬 데이터베이스로 처리하고 데이터베이스 자체에 오프셋을 저장하고 싶습니다. /consumer/KafkaConsumer.html 의 "Kafka 외부에 오프셋 저장".
Spring Kafka (KafkaListener 포함)는 항상 오프셋을 커밋하는 것처럼 보입니다 (따라서 group.id가 필요합니다). 그룹없이 수신 할 수 있도록 커밋을 모두 비활성화하는 방법이 있습니까?
컨테이너 속성 AckMode.MANUAL은 컨테이너에 의한 오프셋 커밋을 비활성화합니다.
이 기사는 인터넷에서 수집됩니다. 재 인쇄 할 때 출처를 알려주십시오.
침해가 발생한 경우 연락 주시기 바랍니다[email protected] 삭제
몇 마디 만하겠습니다