Nachrichten im Confluent Kafka wiedergeben

Question

Ich arbeite mit dem konfluenten Kafka-Stack im Frühjahr, und ich versuche, eine Funktion hinzuzufügen, die es uns ermöglicht, einen Dienst zu starten und Nachrichten zu einer bestimmten Zeit wiederzugeben.

Der Verbraucher ist Setup wie diese

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(); 
} 

Und

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

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

Wissen Sie, wo ich die Einstellungen zu ermöglichen, finden kann mir den Offset auf dem Strom in diesem Szenario zurückspulen?

Answer 1

Ich nehme an, Sie meinen replay nicht reply - Ich habe Ihre Frage bearbeitet.

Spring Cloud Stream stellt derzeit keinen Mechanismus zum Suchen der Offsets bereit.

Sie können statt @KafkaListener spring-kafkas verwenden; implementieren Sie ConsumerSeekAware, die Ihnen den Mechanismus gibt, während des Starts (oder jederzeit) zu suchen.