Spring Integration Kafkaコンシューマのリワインドオフセット

Question

spring-integration-kafkaを使用してKafkaコンシューマのオフセットを巻き戻す方法はありますか？ kafkaコンソールコンシューマスクリプトで使用できる--from-beginningオプションのようなものが欲しい。

マイ消費者の構成は次のようになります。

<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

あなたはconstructor that takes TopicPartitionInitialOffsetsを使用することができます。

Answer 2

auto.offset.resetは次のようになります。早い、最新またはnone