Confluent Kafka의 재생 메시지

Question

봄 부팅시 합류 kafka 스택을 사용하고 있으며 서비스를 시작하고 특정 시간으로 메시지를 다시 재생할 수있는 기능을 추가하려고합니다.

소비자는이

public interface ProductScenarioStream { 
    String SERVICE_REQUESTS_PRODUCT_PRICE = "serviceRequestsProductPrice"; 
    String SERVICE_CONCLUDES_PRODUCT_SCENARIO = "serviceConcludesProductScenario"; 

    @Output(SERVICE_REQUESTS_PRODUCT_PRICE) 
    MessageChannel serviceRequestsProductPrice(); 

    @Input(SERVICE_CONCLUDES_PRODUCT_SCENARIO) 
    SubscribableChannel serviceConcludesProductScenario(); 
} 

그리고

@Service 
@EnableBinding(ProductScenarioStream.class) 
@Profile("stream") 
public class ProductStreamServiceImpl implements ProductStreamService 
{ 
    @Resource 
    private ProductScenarioStream productScenarioStream; 

    @Override 
    public void send(final ServiceRequestsProductPrice event) { 
    ... 
    } 
} 

같은 설정이 내가 나를이 시나리오의 흐름에 오프셋 되감기 할 수 있도록 설정을 찾을 수있는 당신은 알고 계십니까 어디?

Answer 1

나는 replay이 아니라고 생각합니다. reply - 질문이 수정되었습니다.

스프링 클라우드 스트림은 현재 오프셋을 찾기위한 메커니즘을 노출하지 않습니다.

대신 spring-kafka의 @KafkaListener을 사용할 수 있습니다. ConsumerSeekAware을 구현하면 시작 (또는 언제라도) 탐색 할 수있는 메커니즘을 제공합니다.