[jira] [Commented] (KAFKA-9527) Application Reset Tool Returns NPE when --to-timestamp or --by-duration are run on --input-topics with empty partitions

["Marco Lotz (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/KAFKA-9527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276987#comment-17276987 ] 

Marco Lotz commented on KAFKA-9527:
-----------------------------------

[~mjsax] what would be the expected behaviour in this scenario? I see three possible behaviours:
 # Throwing a Kafka specific exception
 # Ignoring the empty partition silently
 # Ignoring the empty partition and logging a warn 

I would guess that 2 is the way to go, because an empty partition is technically speaking, reset to any duration or timestamp that can be requested.

> 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
>            Priority: Minor
>
> 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)