There is a ticket about it: https://issues.apache.org/jira/browse/KAFKA-7480
The current solution is to delete the local copy of the global state store manually to be able to restart. -Matthias On 5/6/20 6:14 AM, Alexander Sibiryakov wrote: > Hello, > > I'm facing an issue in one of our Kafka Streams applications using > GlobalKTable. The idea is to have a GlobalKTable over compacted topic > and be able to re-read it on startup. We had a consumer group and topic > sometime ago, recently I've recreated a topic, requiring consumer > offsets to be reset and consumed from beginning. But application started > to fail with OffsetOutOfRangeException and message "Offsets out of range > with no configured reset policy for partitions..". I do have > auto.offset.reset set in my configuration to "latest", but it is > overridden to "none" for global and restore consumers of Streams > application. > > This exception is resulting in a shutdown loop, and requiring > investigation to understand what is going on. > > > This is the line where it is happening > https://github.com/apache/kafka/blob/trunk/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java#L1244 > > So the question is this behavior of overriding offset reset policy is > intended? If not, please confirm it is a bug, and will submit a patch. > > See the Streams output for detailed configs, traceback and exceptions in > attachment. > > Thanks, > A.
signature.asc
Description: OpenPGP digital signature
