사용하여 Kafka 소비자의 오프셋을 되 감는 방법이 spring-integration-kafka있습니까? --from-beginningkafka 콘솔 소비자 스크립트와 함께 사용할 수있는 옵션 과 같은 것을 원합니다 .
내 소비자 구성은 다음과 같습니다.
<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>
s를 사용하는 생성자를TopicPartitionInitialOffset 사용할 수 있습니다 .
이 기사는 인터넷에서 수집됩니다. 재 인쇄 할 때 출처를 알려주십시오.
침해가 발생한 경우 연락 주시기 바랍니다[email protected] 삭제
몇 마디 만하겠습니다