You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Marco Lotz (Jira)" <ji...@apache.org> on 2021/02/04 13:31:00 UTC
[jira] [Assigned] (KAFKA-9527) Application Reset Tool Returns NPE
when --to-datetime or --by-duration are run on --input-topics with empty
partitions
[ https://issues.apache.org/jira/browse/KAFKA-9527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Marco Lotz reassigned KAFKA-9527:
---------------------------------
Assignee: Marco Lotz (was: jbfletch)
> Application Reset Tool Returns NPE when --to-datetime 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: Marco Lotz
> Priority: Minor
>
> When running the streams application reset tool with --by-duration or --to-datetime 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-datetime 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)