回卷补偿Spring集成Kafka消费

kqlmhetl  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(295)

有没有办法倒带Kafka消费品的偏移量 spring-integration-kafka ? 我想要像这样的东西 --from-beginning 选项,可与kafka控制台使用者脚本一起使用。
我的使用者配置如下所示:

<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>
bf1o4zei

bf1o4zei1#

您可以使用 TopicPartitionInitialOffset s。

相关问题