[jira] [Commented] (KAFKA-12265) Move the BatchAccumulator in KafkaRaftClient to LeaderState

[ https://issues.apache.org/jira/browse/KAFKA-12265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17315988#comment-17315988 ] Rohit Deshpande commented on KAFKA-12265: - [~jagsancio] sorry i started the work but got

[jira] [Assigned] (KAFKA-12265) Move the BatchAccumulator in KafkaRaftClient to LeaderState

[ https://issues.apache.org/jira/browse/KAFKA-12265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rohit Deshpande reassigned KAFKA-12265: --- Assignee: Rohit Deshpande > Move the BatchAccumulator in KafkaRaftClient to

[jira] [Commented] (KAFKA-12265) Move the BatchAccumulator in KafkaRaftClient to LeaderState

[ https://issues.apache.org/jira/browse/KAFKA-12265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17299896#comment-17299896 ] Rohit Deshpande commented on KAFKA-12265: - thanks [~jagsancio] I can work on this one. > Move

[jira] [Commented] (KAFKA-10821) Send cluster id information with the FetchSnapshot request

[ https://issues.apache.org/jira/browse/KAFKA-10821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17299322#comment-17299322 ] Rohit Deshpande commented on KAFKA-10821: - ok thanks [~jagsancio] can you please assign me some

[jira] [Commented] (KAFKA-10821) Send cluster id information with the FetchSnapshot request

[ https://issues.apache.org/jira/browse/KAFKA-10821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17297762#comment-17297762 ] Rohit Deshpande commented on KAFKA-10821: - [~jagsancio] can I please work on this?  As per

[jira] [Commented] (KAFKA-12253) Add tests that cover all of all of the cases for ReplicatedLog::validateOffsetAndEpoch

[ https://issues.apache.org/jira/browse/KAFKA-12253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17297068#comment-17297068 ] Rohit Deshpande commented on KAFKA-12253: - [~jagsancio] created pull request:

[jira] [Commented] (KAFKA-10788) Streamlining Tests in CachingInMemoryKeyValueStoreTest

[ https://issues.apache.org/jira/browse/KAFKA-10788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17293907#comment-17293907 ] Rohit Deshpande commented on KAFKA-10788: - thanks [~cadonna] makes sense to me. Will post the

[jira] [Commented] (KAFKA-12253) Add tests that cover all of all of the cases for ReplicatedLog::validateOffsetAndEpoch

[ https://issues.apache.org/jira/browse/KAFKA-12253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17293060#comment-17293060 ] Rohit Deshpande commented on KAFKA-12253: - Thank you. Will go through those test classes and

[jira] [Assigned] (KAFKA-12253) Add tests that cover all of all of the cases for ReplicatedLog::validateOffsetAndEpoch

[ https://issues.apache.org/jira/browse/KAFKA-12253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rohit Deshpande reassigned KAFKA-12253: --- Assignee: Rohit Deshpande > Add tests that cover all of all of the cases for >

[jira] [Commented] (KAFKA-12253) Add tests that cover all of all of the cases for ReplicatedLog::validateOffsetAndEpoch

[ https://issues.apache.org/jira/browse/KAFKA-12253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17292687#comment-17292687 ] Rohit Deshpande commented on KAFKA-12253: - [~jagsancio] can I please pick this up? Do you

[jira] [Commented] (KAFKA-10788) Streamlining Tests in CachingInMemoryKeyValueStoreTest

[ https://issues.apache.org/jira/browse/KAFKA-10788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17292588#comment-17292588 ] Rohit Deshpande commented on KAFKA-10788: - [~sagarrao] [~guozhang] I started making changes to 

[jira] [Resolved] (KAFKA-10871) StreamTask shouldn't take WallClockTime as input parameter in process method

[ https://issues.apache.org/jira/browse/KAFKA-10871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rohit Deshpande resolved KAFKA-10871. - Resolution: Not A Bug > StreamTask shouldn't take WallClockTime as input parameter in

[jira] [Commented] (KAFKA-10871) StreamTask shouldn't take WallClockTime as input parameter in process method

[ https://issues.apache.org/jira/browse/KAFKA-10871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254408#comment-17254408 ] Rohit Deshpande commented on KAFKA-10871: - got it thanks [~mjsax] i will go ahead and close

[jira] [Commented] (KAFKA-10871) StreamTask shouldn't take WallClockTime as input parameter in process method

[ https://issues.apache.org/jira/browse/KAFKA-10871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252522#comment-17252522 ] Rohit Deshpande commented on KAFKA-10871: - cc [~guozhang] [~mjsax] [~vvcephei]  > StreamTask

[jira] [Created] (KAFKA-10871) StreamTask shouldn't take WallClockTime as input parameter in process method

Rohit Deshpande created KAFKA-10871: --- Summary: StreamTask shouldn't take WallClockTime as input parameter in process method Key: KAFKA-10871 URL: https://issues.apache.org/jira/browse/KAFKA-10871

[jira] [Commented] (KAFKA-10062) Add a method to retrieve the current timestamp as known by the Streams app

[ https://issues.apache.org/jira/browse/KAFKA-10062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250024#comment-17250024 ] Rohit Deshpande commented on KAFKA-10062: - got it thanks. > Add a method to retrieve the

[jira] [Comment Edited] (KAFKA-10062) Add a method to retrieve the current timestamp as known by the Streams app

[ https://issues.apache.org/jira/browse/KAFKA-10062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17248693#comment-17248693 ] Rohit Deshpande edited comment on KAFKA-10062 at 12/14/20, 2:58 PM:

[jira] [Commented] (KAFKA-10062) Add a method to retrieve the current timestamp as known by the Streams app

[ https://issues.apache.org/jira/browse/KAFKA-10062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17248693#comment-17248693 ] Rohit Deshpande commented on KAFKA-10062: - [~psmolinski] [~mjsax] [~vvcephei] created pull

[jira] [Commented] (KAFKA-10788) Streamlining Tests in CachingInMemoryKeyValueStoreTest

[ https://issues.apache.org/jira/browse/KAFKA-10788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17248691#comment-17248691 ] Rohit Deshpande commented on KAFKA-10788: - [~sagarrao] can this ticket be assigned to me? >

[jira] [Commented] (KAFKA-10629) TopologyTestDriver should not require a Properties arg

[ https://issues.apache.org/jira/browse/KAFKA-10629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17241301#comment-17241301 ] Rohit Deshpande commented on KAFKA-10629: - thanks [~mjsax]  > TopologyTestDriver should not

[jira] [Commented] (KAFKA-10629) TopologyTestDriver should not require a Properties arg

[ https://issues.apache.org/jira/browse/KAFKA-10629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239858#comment-17239858 ] Rohit Deshpande commented on KAFKA-10629: - [~mjsax] [~vvcephei] created pull request:

[jira] [Commented] (KAFKA-10062) Add a method to retrieve the current timestamp as known by the Streams app

[ https://issues.apache.org/jira/browse/KAFKA-10062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17233230#comment-17233230 ] Rohit Deshpande commented on KAFKA-10062: - Thank you [~wbottrell]  > Add a method to retrieve

[jira] [Assigned] (KAFKA-10062) Add a method to retrieve the current timestamp as known by the Streams app

[ https://issues.apache.org/jira/browse/KAFKA-10062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rohit Deshpande reassigned KAFKA-10062: --- Assignee: Rohit Deshpande (was: William Bottrell) > Add a method to retrieve the

[jira] [Commented] (KAFKA-10062) Add a method to retrieve the current timestamp as known by the Streams app

[ https://issues.apache.org/jira/browse/KAFKA-10062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17233158#comment-17233158 ] Rohit Deshpande commented on KAFKA-10062: - Thanks [~cadonna] I will wait for the response. >

[jira] [Commented] (KAFKA-10062) Add a method to retrieve the current timestamp as known by the Streams app

[ https://issues.apache.org/jira/browse/KAFKA-10062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17232574#comment-17232574 ] Rohit Deshpande commented on KAFKA-10062: - [~mjsax] [~vvcephei] [~psmolinski] can I pick this up

[jira] [Comment Edited] (KAFKA-10629) TopologyTestDriver should not require a Properties arg

[ https://issues.apache.org/jira/browse/KAFKA-10629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17225189#comment-17225189 ] Rohit Deshpande edited comment on KAFKA-10629 at 11/3/20, 7:21 AM: ---

[jira] [Comment Edited] (KAFKA-10629) TopologyTestDriver should not require a Properties arg

[ https://issues.apache.org/jira/browse/KAFKA-10629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17225189#comment-17225189 ] Rohit Deshpande edited comment on KAFKA-10629 at 11/3/20, 7:20 AM: ---

[jira] [Commented] (KAFKA-10629) TopologyTestDriver should not require a Properties arg

[ https://issues.apache.org/jira/browse/KAFKA-10629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17225189#comment-17225189 ] Rohit Deshpande commented on KAFKA-10629: - Thanks [~mjsax] Created

[jira] [Assigned] (KAFKA-10629) TopologyTestDriver should not require a Properties arg

[ https://issues.apache.org/jira/browse/KAFKA-10629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rohit Deshpande reassigned KAFKA-10629: --- Assignee: Rohit Deshpande > TopologyTestDriver should not require a Properties arg

[jira] [Commented] (KAFKA-10629) TopologyTestDriver should not require a Properties arg

[ https://issues.apache.org/jira/browse/KAFKA-10629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17222582#comment-17222582 ] Rohit Deshpande commented on KAFKA-10629: - [~vvcephei] can I pick this up?  >

[jira] [Commented] (KAFKA-6579) Consolidate window store and session store unit tests into a single class

[ https://issues.apache.org/jira/browse/KAFKA-6579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17202959#comment-17202959 ] Rohit Deshpande commented on KAFKA-6579: [~guozhang] can I pick this up?  > Consolidate window