나는 RabbitMQ를 실행하려고하는 Apache Kafka의 사용자입니다. Kafka는 소비자가 이전에 생성 된 모든 메시지를 소비하도록 지원합니다. (카프카의 로그에서 '오프셋'을 다시 넓혀서)새 소비자가 RabbitMQ에서 과거에 생성 된 메시지를 얼마나 소비합니까?
RabbitMQ가 동일한 기능을 갖고 있는지 여부를 알고 싶습니다. 는 (새로운 소비자 와서 특정 시점 이후 모든 메시지를 요청합니다.)
내가 RabbitMQ 그것은하지 않습니다 같은 기능
이 있는지 여부를 알고 싶습니다.
Kafka는 해당 기능을 위해 특별히 제작되었습니다. 즉, 지점에서 앞으로 이동할 수있는 이벤트 로그입니다.
RabbitMQ는 메시지 큐입니다. 선입 선출. 메시지가 처리되면 완료되고 사라집니다. 통과 할 기록이나 로그가 없습니다.
는 RabbitMQ에 대해 "최근의 역사"플러그인이있다, 그러나 이것은 카프카 설정 같은 기능을 제공하지 않습니다.
https://github.com/rabbitmq/rabbitmq-recent-history-exchange#readme
그것은 단지 당신이 뭔가 "새로운 소비자가 새 메시지를 얻기 위해 계속하기 전에, 지난 20 메시지를 얻어야한다 '라고 할 수 있습니다.
카프카 (Kafka)는 훨씬 더 광범위한 역사와 시작부터 시작하여 앞으로 나아갈 수있는 능력을 제공합니다.
RabbitMQ 소비자는 가입 후 생성 된 메시지를 받게됩니다. 맞습니까? 덕분에 – syko
대기열에 단일 사용자가 있다고 가정하면 소비자는 연결 후 소비를 시작한 후 대기열에 메시지를 수신합니다. 소비자가 연결되기 전에 대기열에 5 개의 메시지가있는 경우 소비자는 해당 메시지 5 개와 모든 메시지를 수신합니다. –
그러나 5 개의 메시지가 사라지고 다른 소비자가 동일한 대기열에 연결되면 두 번째 소비자는 메시지가 이미 사라 졌으므로 해당 메시지를 수신하십시오. 내가 언급 한 플러그인을 제외하고는 히스토리가 없습니다. –