You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@kafka.apache.org by "meigong.wang" <me...@okcoin.com> on 2018/11/29 06:08:20 UTC

kafka-streams batch restore state

When I restart my kafka-streams application, sometimes I can see following log：


[Consumer clientId=market-kline-stream-wmg-ticker-d891eeaf-2932-45b8-b7e2-9720904a69a5-StreamThread-3-restore-consumer, groupId=] Resetting offset for partition market-kline-stream-wmg-ticker-KSTREAM-REDUCE-STATE-STORE-0000000003-changelog-0 to offset 0.


I am sure the rocksdb directoryexists，I didn't change any configuration，what happened?Is this a bug in kafka-streams，the version is 1.1.1.