jbfletch created KAFKA-9527:
-------------------------------
Summary: Application Reset Tool Returns NPE when --to-timestamp or
--by-duration are run on --input-topics with empty partitions
Key: KAFKA-9527
URL: https://issues.apache.org/jira/browse/KAFKA-9527
Project: Kafka
Issue Type: Bug
Components: streams, tools
Affects Versions: 2.3.0
Reporter: jbfletch
Assignee: jbfletch
When running the streams application reset tool with --by-duration or
--to-timestamp if any partitions for a given input topic are empty a NPE is
thrown. I tested this with a topic with 3 partitions, I received a NPE until
all 3 partitions had at least one message. The behavior was the same for both
--to-timestamp and --by-duration.
Error below:
Reset-offsets for input topics [sample-cdc-topic]Reset-offsets for input topics
[sample-cdc-topic]Following input topics offsets will be reset to (for consumer
group des-demo-stream)ERROR:
java.lang.NullPointerExceptionjava.lang.NullPointerException at
kafka.tools.StreamsResetter.resetToDatetime(StreamsResetter.java:496) at
kafka.tools.StreamsResetter.maybeReset(StreamsResetter.java:426) at
kafka.tools.StreamsResetter.maybeResetInputAndSeekToEndIntermediateTopicOffsets(StreamsResetter.java:374)
at kafka.tools.StreamsResetter.run(StreamsResetter.java:164) at
kafka.tools.StreamsResetter.run(StreamsResetter.java:131) at
kafka.tools.StreamsResetter.main(StreamsResetter.java:678)
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
