요구사항: 스프링 부팅 애플리케이션이 실행되면 데이터베이스나 캐시에서 일부 구성 정보가 읽히고, Kafka는 구성 정보 변경 사항을 구독하는 데 사용됩니다. 앱이 최신 설정 정보로 시작하기 때문에 과거 Kafka 설정 업데이트에 관한 메시지는 의미가 없고, 과거 메시지를 사용하면 문제가 발생할 수 있습니다.
Spring Boot 앱이 재시작된 후, 주제에 관한 오래된 데이터를 어떻게 폐기하는지에 대한 질문이 있습니다해당 주제의 역사에 관한 카프카 메시지는 받지 못합니다이? 사실 이 문제는 시작 오프셋을 설정함으로써 해결할 수 있는데, 구독자는 메시지 구독 전에 주제의 오프셋을 마지막 위치로 설정할 수 있습니다.
spring.kafka.consumer.auto-offset-reset 기능이 최고로 설정되어 있더라도, 소비자는 메시지를 마지막으로 수신한 플래그 비트에서 메시지를 읽게 되며, 앱을 종료할 때 프로듀서가 많은 메시지를 보낼 경우 재시작 후 많은 메시지를 읽게 됩니다.
면책 조항: Code Farmer Network에서 발행하는 모든 소프트웨어, 프로그래밍 자료 또는 기사는 학습 및 연구 목적으로만 사용됩니다; 위 내용은 상업적 또는 불법적인 목적으로 사용되지 않으며, 그렇지 않으면 모든 책임이 사용자에게 부담됩니다. 이 사이트의 정보는 인터넷에서 가져온 것이며, 저작권 분쟁은 이 사이트와는 관련이 없습니다. 위 내용은 다운로드 후 24시간 이내에 컴퓨터에서 완전히 삭제해야 합니다. 프로그램이 마음에 드신다면, 진짜 소프트웨어를 지원하고, 등록을 구매하며, 더 나은 진짜 서비스를 받아주세요. 침해가 있을 경우 이메일로 연락해 주시기 바랍니다.
Mail To:help@itsvse.com
2021-11-14 21:42:26에 게시됨
|
|
|
집주인|
2021-11-15 10:37:05에 게시됨
|
