有没有办法倒带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>
1条答案
按热度按时间bf1o4zei1#
您可以使用
TopicPartitionInitialOffset
s。