Rückspulversatz für Spring Integration Kafka consumer

Question

Gibt es eine Möglichkeit, den Offset des Kafka-Verbrauchers über spring-integration-kafka zurückzuspulen? Ich möchte etwas wie die --from-beginning Option, die mit Kafka-Konsole Consumer-Skript verwendet werden kann.

Meine Verbraucher Konfiguration sieht wie folgt aus:

<bean id="consumerProperties" 
    class="org.springframework.beans.factory.config.PropertiesFactoryBean"> 
    <property name="properties"> 
     <props> 
      <prop key="auto.offset.reset">smallest</prop> 
      <prop key="socket.receive.buffer.bytes">10485760</prop> <!-- 10M --> 
      <prop key="fetch.message.max.bytes">5242880</prop> 
      <prop key="auto.commit.interval.ms">1000</prop> 
     </props> 
    </property> 
</bean> 

Answer 1

Sie die constructor that takes TopicPartitionInitialOffsets verwenden können.

Answer 2

auto.offset.reset soll frühestens neueste oder keine