[jira] [Created] (KAFKA-17446) Kafka streams stuck in rebalancing

Rohit Bobade created KAFKA-17446: Summary: Kafka streams stuck in rebalancing Key: KAFKA-17446 URL: https://issues.apache.org/jira/browse/KAFKA-17446 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-17445) Kafka streams keeps rebalancing with the following reasons

Rohit Bobade created KAFKA-17445: Summary: Kafka streams keeps rebalancing with the following reasons Key: KAFKA-17445 URL: https://issues.apache.org/jira/browse/KAFKA-17445 Project: Kafka

[jira] [Created] (KAFKA-17380) Kafka Streams few partition stuck in processing - fixed after restart

Rohit Bobade created KAFKA-17380: Summary: Kafka Streams few partition stuck in processing - fixed after restart Key: KAFKA-17380 URL: https://issues.apache.org/jira/browse/KAFKA-17380 Project: Kafka

[jira] [Created] (KAFKA-15520) Kafka Streams Stateful Aggregation Rebalancing causing processing to pause on all partitions

Rohit Bobade created KAFKA-15520: Summary: Kafka Streams Stateful Aggregation Rebalancing causing processing to pause on all partitions Key: KAFKA-15520 URL: https://issues.apache.org/jira/browse/KAFKA-15520

Query regarding implementation of KStreams with Hbase

some transformation and write it to a hbase table Regards Rohit M

Regarding Jira Account Creation

Hi, I am Rohit, working as a Software Engineer at Confluent. Recently I started working on https://issues.apache.org/jira/browse/KAFKA-14401. And raised a PR for the same here(https://github.com/apache/kafka/pull/13361). I wanted to have a JIRA account to assign the issue to myself and work on

[jira] [Created] (KAFKA-13960) ERROR Shutdown broker because all log dirs in c:\kafka\kafka-logs have failed (kafka.log.LogManager)

rohit k created KAFKA-13960: --- Summary: ERROR Shutdown broker because all log dirs in c:\kafka\kafka-logs have failed (kafka.log.LogManager) Key: KAFKA-13960 URL: https://issues.apache.org/jira/browse/KAFKA-13960

[jira] [Created] (KAFKA-13269) Kafka Streams Aggregation data loss between instance restarts and rebalances

Rohit Bobade created KAFKA-13269: Summary: Kafka Streams Aggregation data loss between instance restarts and rebalances Key: KAFKA-13269 URL: https://issues.apache.org/jira/browse/KAFKA-13269 Project

[jira] [Created] (KAFKA-12865) Documentation error for Admin Client API in describe ACLs

Rohit Sachan created KAFKA-12865: Summary: Documentation error for Admin Client API in describe ACLs Key: KAFKA-12865 URL: https://issues.apache.org/jira/browse/KAFKA-12865 Project: Kafka

Re: [VOTE] KIP-622 Add currentSystemTimeMs and currentStreamTimeMs to ProcessorContext

kProcessorContext#setRecordTimestamp which does the same work. Please let me know if you have any thoughts or concerns with this change. Thanks, Roohit On Fri, Dec 4, 2020 at 7:31 PM Rohit Deshpande wrote: > Hello all, > I am closing the vote for this KIP: > https://cwiki.apache.org/confluence/di

[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 para

[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-

Re: [VOTE] KIP-622 Add currentSystemTimeMs and currentStreamTimeMs to ProcessorContext

-clock time 2. long currentStreamTimeMs() to fetch maximum timestamp of any record yet processed by the task Thanks, Rohit On 2020/12/01 16:09:54, Bill Bejeck wrote: > Sorry for jumping into this so late, > > Thanks for the KIP, I'm a +1 (binding) > > -Bill > > On Sun

Re: [VOTE] KIP-680: TopologyTestDriver should not require a Properties argument

pull/9660> Thanks, Rohit On Mon, Nov 23, 2020 at 9:58 AM Rohit Deshpande wrote: > Thanks John and Matthias. > Waiting for 1 more binding vote. > Thanks, > Rohit > > On Sat, Nov 21, 2020 at 11:01 AM Matthias J. Sax wrote: > >> +1 (binding) >> >> On 11/2

Re: [DISCUSS] KIP-622 Add currentSystemTimeMs and currentStreamTimeMs to ProcessorContext

streamTime and can take an action on incoming record. Thanks, Rohit On 2020/08/14 05:07:04, "John Roesler" wrote: > Thanks for the reply, Matthias,> > > I see what you mean. I suppose I was thinking that we would pass in the > cached system time, which is also what we’r

Re: [VOTE] KIP-680: TopologyTestDriver should not require a Properties argument

Thanks John and Matthias. Waiting for 1 more binding vote. Thanks, Rohit On Sat, Nov 21, 2020 at 11:01 AM Matthias J. Sax wrote: > +1 (binding) > > On 11/20/20 7:43 PM, John Roesler wrote: > > Thanks again for the KIP, Rohit. > > > > I’m +1 (binding) > > >

Re: [VOTE] KIP-680: TopologyTestDriver should not require a Properties argument

Thanks Guozhang. Waiting for binding votes. Thanks, Rohit On Tue, Nov 17, 2020 at 10:13 AM Guozhang Wang wrote: > +1, thanks Rohit. > > > Guozhang > > On Sun, Nov 15, 2020 at 11:53 AM Rohit Deshpande > wrote: > > > Hello all, > > I would like to start v

[VOTE] KIP-680: TopologyTestDriver should not require a Properties argument

/r5d3d0afc6feb5e18ade47aefbd88534f1b19b2f550a14d33cbc7a0dd%40%3Cdev.kafka.apache.org%3E Jira for the KIP: https://issues.apache.org/jira/browse/KAFKA-10629 If we end up making changes, they will look like this: https://github.com/apache/kafka/compare/trunk...rohitrmd:KAFKA-10629 Thanks, Rohit

Re: [DISCUSS] KIP-680: TopologyTestDriver should not require a Properties argument

Hi John and Matthias, I have updated the wiki with your suggestions. https://cwiki.apache.org/confluence/display/KAFKA/KIP-680%3A+TopologyTestDriver+should+not+require+a+Properties+argument Thanks, Rohit On Fri, Nov 6, 2020 at 3:23 PM Rohit Deshpande wrote: > Thanks John, I will go ahead

Re: [DISCUSS] KIP-680: TopologyTestDriver should not require a Properties argument

Thanks John, I will go ahead and update the KIP with a randomized application id requirement. On Fri, Nov 6, 2020 at 3:12 PM John Roesler wrote: > Hi Rohit, > > Ah, indeed, that was my mistake. I made a bad assumption about the code. > > Since we are already cleaning up, then I

Re: [DISCUSS] KIP-680: TopologyTestDriver should not require a Properties argument

he directory have to be unique in each test? If yes, then I agree that we can tackle RocksDb directories cleanup and creating unique directory tasks in separate KIP. Thanks, Rohit On Fri, Nov 6, 2020 at 7:12 AM John Roesler wrote: > Hello Rohit, > > Thanks for picking this up! I think your

Re: [DISCUSS] KIP-680: TopologyTestDriver should not require a Properties argument

/apache/kafka/streams/scala/utils/TestDriver.scala#L32-L35 which is used in multiple test classes and seems redundant. I agree with your suggestion. Thanks, Rohit On Tue, Nov 3, 2020 at 3:19 PM Matthias J. Sax wrote: > Thanks for the KIP Rohit. > > Wondering, if we should

[DISCUSS] KIP-680: TopologyTestDriver should not require a Properties argument

up making changes, they will look like this: https://github.com/apache/kafka/compare/trunk...rohitrmd:KAFKA-10629 Please have a look and let me know what you think. Thanks, Rohit

Re: Permission for contribution

Hi Boyang, My wiki id is rohitdeshaws Thanks, Rohit On Thu, Oct 29, 2020 at 1:59 PM Rohit Deshpande wrote: > I don't know how to create wiki id. I am following this documentation: > https://kafka.apache.org/contributing > > On Thu, Oct 29, 2020 at 1:40 PM Boyang Chen > w

Re: Permission for contribution

I don't know how to create wiki id. I am following this documentation: https://kafka.apache.org/contributing On Thu, Oct 29, 2020 at 1:40 PM Boyang Chen wrote: > Added you to the JIRA. What's your id for wiki? > > On Thu, Oct 29, 2020 at 1:23 PM rohit deshpande > >

Re: Permission for contribution

I forgot to provide details. My email id: rohitmdeshpa...@gmail.com This request is regarding code contribution. Thanks, Rohit On Thu, Oct 29, 2020 at 11:58 AM rohit deshpande wrote: > Hi, > I would like to get permission for the contribution. > My jira id: rohitdeshaws > > Thanks, > Rohit >

Permission for contribution

Hi, I would like to get permission for the contribution. My jira id: rohitdeshaws Thanks, Rohit

[jira] [Created] (KAFKA-10471) TimeIndex handling may cause data loss in certain back to back failure

Rohit Shekhar created KAFKA-10471: - Summary: TimeIndex handling may cause data loss in certain back to back failure Key: KAFKA-10471 URL: https://issues.apache.org/jira/browse/KAFKA-10471 Project

[jira] [Created] (KAFKA-9493) Error after some time in Kafka on Kubernetes with PVC

Rohit Agrawal created KAFKA-9493: Summary: Error after some time in Kafka on Kubernetes with PVC Key: KAFKA-9493 URL: https://issues.apache.org/jira/browse/KAFKA-9493 Project: Kafka Issue

data exchange format to use with Apache Kakfa that provides schema validation

will it be as i can't afford more then 5 to 6 ms for schema validation and deserialisation? any inputs please? We will be processing thousands of transactions per second and SLA for each transaction is 150ms so i am looking for something that's very fast. Regards,Rohit Sent from Yaho

[jira] [Created] (KAFKA-7512) java.lang.ClassCastException: java.util.Date cannot be cast to java.lang.Number

Rohit Kumar Gupta created KAFKA-7512: Summary: java.lang.ClassCastException: java.util.Date cannot be cast to java.lang.Number Key: KAFKA-7512 URL: https://issues.apache.org/jira/browse/KAFKA-7512