[jira] [Created] (KAFKA-8737) TaskMigrated Exception while rebalancing kafka streams

2019-07-30 Thread KUMAR (JIRA)
KUMAR created KAFKA-8737: Summary: TaskMigrated Exception while rebalancing kafka streams Key: KAFKA-8737 URL: https://issues.apache.org/jira/browse/KAFKA-8737 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-8737) TaskMigrated Exception while rebalancing kafka streams

2019-10-31 Thread KUMAR (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16964410#comment-16964410 ] KUMAR commented on KAFKA-8737: -- Hi Bill Is there a plan to fix this issue similar to earlier fix for 

[jira] [Created] (KAFKA-5504) Kafka controller is not getting elected

2017-06-22 Thread Ashish Kumar (JIRA)
Ashish Kumar created KAFKA-5504: --- Summary: Kafka controller is not getting elected Key: KAFKA-5504 URL: https://issues.apache.org/jira/browse/KAFKA-5504 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-5504) Kafka controller is not getting elected

2017-06-22 Thread Ashish Kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish Kumar updated KAFKA-5504: Description: I am having a kafka cluster of 20 nodes and I was facing the issue of

[jira] [Updated] (KAFKA-5504) Kafka controller is not getting elected

2017-06-22 Thread Ashish Kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish Kumar updated KAFKA-5504: Description: I am having a kafka cluster of 20 nodes and I was facing issue of under-replicated

[jira] [Commented] (KAFKA-1614) Partition log directory name and segments information exposed via JMX

2017-09-11 Thread pranay kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16161077#comment-16161077 ] pranay kumar commented on KAFKA-1614: - Hi, I have kafka version 0.8.2.1.0. And kafka manager working

[jira] [Commented] (KAFKA-1614) Partition log directory name and segments information exposed via JMX

2017-09-11 Thread pranay kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16161144#comment-16161144 ] pranay kumar commented on KAFKA-1614: - Thanks [~sergey.vergun] for reply. When I am trying to install

[jira] [Commented] (KAFKA-5632) Message headers not supported by Kafka Streams

2017-11-26 Thread Narendra Kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16266129#comment-16266129 ] Narendra Kumar commented on KAFKA-5632: --- Any update on this ? In streams 1.0.0 , I am able to get

[jira] [Commented] (KAFKA-5632) Message headers not supported by Kafka Streams

2017-12-03 Thread Narendra Kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16276122#comment-16276122 ] Narendra Kumar commented on KAFKA-5632: --- [~mjsax] How about putting headers as a field in

[jira] [Commented] (KAFKA-6298) Line numbers on log messages are incorrect

2017-12-04 Thread Narendra Kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16277878#comment-16277878 ] Narendra Kumar commented on KAFKA-6298: --- I also tested the LocationAwareLogger with log4j and

[jira] [Commented] (KAFKA-6339) Integration test with embedded kafka not working

2017-12-13 Thread Narendra Kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16290024#comment-16290024 ] Narendra Kumar commented on KAFKA-6339: --- Hi Dhruv, Can you please enable debug logging and provide

[jira] [Comment Edited] (KAFKA-6339) Integration test with embedded kafka not working

2017-12-13 Thread Narendra Kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16290024#comment-16290024 ] Narendra Kumar edited comment on KAFKA-6339 at 12/13/17 10:13 PM: -- Hi

[jira] [Updated] (KAFKA-6298) Line numbers on log messages are incorrect

2017-12-11 Thread Narendra Kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Narendra Kumar updated KAFKA-6298: -- Flags: (was: Patch) > Line numbers on log messages are incorrect >

[jira] [Updated] (KAFKA-6298) Line numbers on log messages are incorrect

2017-12-11 Thread Narendra Kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Narendra Kumar updated KAFKA-6298: -- Flags: Patch > Line numbers on log messages are incorrect >

[jira] [Commented] (KAFKA-6339) Integration test with embedded kafka not working

2017-12-11 Thread Narendra Kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16286332#comment-16286332 ] Narendra Kumar commented on KAFKA-6339: --- Hi Dhruv, Sorry for the delayed response. This does not

[jira] [Commented] (KAFKA-6298) Line numbers on log messages are incorrect

2017-12-06 Thread Narendra Kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280878#comment-16280878 ] Narendra Kumar commented on KAFKA-6298: --- I would like to work on this, if nobody is working on this

[jira] [Commented] (KAFKA-6339) Integration test with embedded kafka.

2017-12-09 Thread Narendra Kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16284848#comment-16284848 ] Narendra Kumar commented on KAFKA-6339: --- Hi Dhruv, Can you please let us know more about the problem

[jira] [Commented] (KAFKA-2857) ConsumerGroupCommand throws GroupCoordinatorNotAvailableException when describing a non-existent group before the offset topic is created

2018-06-11 Thread Sampath Kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16507929#comment-16507929 ] Sampath Kumar commented on KAFKA-2857: -- We are still observing group coordinator not available in

[jira] [Created] (KAFKA-7017) GroupCoordinator response error: Broker: Group coordinator not available

2018-06-07 Thread Sampath Kumar (JIRA)
Sampath Kumar created KAFKA-7017: Summary: GroupCoordinator response error: Broker: Group coordinator not available Key: KAFKA-7017 URL: https://issues.apache.org/jira/browse/KAFKA-7017 Project:

[jira] [Created] (KAFKA-6847) PeriodicProducerExpirationCheck

2018-05-02 Thread Sunil Kumar (JIRA)
Sunil Kumar created KAFKA-6847: -- Summary: PeriodicProducerExpirationCheck Key: KAFKA-6847 URL: https://issues.apache.org/jira/browse/KAFKA-6847 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-6536) Streams quickstart pom.xml is missing versions for a bunch of plugins

2018-02-13 Thread Yaswanth Kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362153#comment-16362153 ] Yaswanth Kumar commented on KAFKA-6536: --- I would like to start working on this issue. > Streams

[jira] [Commented] (KAFKA-6536) Streams quickstart pom.xml is missing versions for a bunch of plugins

2018-02-14 Thread Yaswanth Kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16363641#comment-16363641 ] Yaswanth Kumar commented on KAFKA-6536: --- I have added the versions and raised a pull request

[jira] [Commented] (KAFKA-2526) Console Producer / Consumer's serde config is not working

2018-02-14 Thread Yaswanth Kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16363649#comment-16363649 ] Yaswanth Kumar commented on KAFKA-2526: --- is this issue resolved? If not, I would like to take it up.

[jira] [Commented] (KAFKA-6567) KStreamWindowReduce can be replaced by KStreamWindowAggregate

2018-02-17 Thread Yaswanth Kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16368149#comment-16368149 ] Yaswanth Kumar commented on KAFKA-6567: --- I would like to start working on this issue. I am going to

[jira] [Commented] (KAFKA-6536) Streams quickstart pom.xml is missing versions for a bunch of plugins

2018-02-15 Thread Yaswanth Kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16365411#comment-16365411 ] Yaswanth Kumar commented on KAFKA-6536: --- Great thanks! > Streams quickstart pom.xml is missing

[jira] [Created] (KAFKA-6402) KStream Ktable join integration test fails randomly

2017-12-26 Thread Narendra Kumar (JIRA)
Narendra Kumar created KAFKA-6402: - Summary: KStream Ktable join integration test fails randomly Key: KAFKA-6402 URL: https://issues.apache.org/jira/browse/KAFKA-6402 Project: Kafka Issue

[jira] [Commented] (KAFKA-7154) Apache kafka getting shut down everytime it is started

2018-07-15 Thread Pushkar Kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16544519#comment-16544519 ] Pushkar Kumar commented on KAFKA-7154: -- Hi [~omkreddy] Thanks for the info. I tried *nohup

[jira] [Updated] (KAFKA-7154) Apache kafka getting shut down everytime it is started

2018-07-12 Thread Pushkar Kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pushkar Kumar updated KAFKA-7154: - Attachment: server.log.txt > Apache kafka getting shut down everytime it is started >

[jira] [Updated] (KAFKA-7154) Apache kafka getting shut down everytime it is started

2018-07-12 Thread Pushkar Kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pushkar Kumar updated KAFKA-7154: - Attachment: server.txt > Apache kafka getting shut down everytime it is started >

[jira] [Updated] (KAFKA-7154) Apache kafka getting shut down everytime it is started

2018-07-12 Thread Pushkar Kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pushkar Kumar updated KAFKA-7154: - Attachment: (was: server.log.txt) > Apache kafka getting shut down everytime it is started >

[jira] [Commented] (KAFKA-7154) Apache kafka getting shut down everytime it is started

2018-07-12 Thread Pushkar Kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16541460#comment-16541460 ] Pushkar Kumar commented on KAFKA-7154: -- Also attached the kafka server.log file > Apache kafka

[jira] [Created] (KAFKA-6797) Connect oracle database to kafka and stream data

2018-04-17 Thread Ujjwal Kumar (JIRA)
Ujjwal Kumar created KAFKA-6797: --- Summary: Connect oracle database to kafka and stream data Key: KAFKA-6797 URL: https://issues.apache.org/jira/browse/KAFKA-6797 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-7511) Fetch offset 2287878 is out of range for partition CommitTrn-0, resetting offset

2018-10-16 Thread Hitesh Kumar (JIRA)
Hitesh Kumar created KAFKA-7511: --- Summary: Fetch offset 2287878 is out of range for partition CommitTrn-0, resetting offset Key: KAFKA-7511 URL: https://issues.apache.org/jira/browse/KAFKA-7511

[jira] [Updated] (KAFKA-7511) Fetch offset 2287878 is out of range for partition CommitTrn-0, resetting offset

2018-10-16 Thread Hitesh Kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hitesh Kumar updated KAFKA-7511: Priority: Critical (was: Major) > Fetch offset 2287878 is out of range for partition

[jira] [Updated] (KAFKA-7590) GETTING HUGE MESSAGE STRUCTURE THROUGH JMS CONNECTOR

2018-11-05 Thread Chenchu Lakshman kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chenchu Lakshman kumar updated KAFKA-7590: -- Description: Message

[jira] [Updated] (KAFKA-7590) GETTING HUGE MESSAGE STRUCTURE THROUGH JMS CONNECTOR

2018-11-11 Thread Chenchu Lakshman kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chenchu Lakshman kumar updated KAFKA-7590: -- Description: Message

[jira] [Resolved] (KAFKA-7590) GETTING HUGE MESSAGE STRUCTURE THROUGH JMS CONNECTOR

2018-11-11 Thread Chenchu Lakshman kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chenchu Lakshman kumar resolved KAFKA-7590. --- Resolution: Fixed > GETTING HUGE MESSAGE STRUCTURE THROUGH JMS CONNECTOR >

[jira] [Created] (KAFKA-7623) SMT STRUCT to MASK or FILTER

2018-11-13 Thread Chenchu Lakshman kumar (JIRA)
Chenchu Lakshman kumar created KAFKA-7623: - Summary: SMT STRUCT to MASK or FILTER Key: KAFKA-7623 URL: https://issues.apache.org/jira/browse/KAFKA-7623 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-7624) HOW TO FILETER NESTED THROUGH KAFKA CONNECT

2018-11-14 Thread Chenchu Lakshman kumar (JIRA)
Chenchu Lakshman kumar created KAFKA-7624: - Summary: HOW TO FILETER NESTED THROUGH KAFKA CONNECT Key: KAFKA-7624 URL: https://issues.apache.org/jira/browse/KAFKA-7624 Project: Kafka

[jira] [Resolved] (KAFKA-7623) SMT STRUCT to MASK or FILTER

2018-11-14 Thread Chenchu Lakshman kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chenchu Lakshman kumar resolved KAFKA-7623. --- Resolution: Fixed > SMT STRUCT to MASK or FILTER >

[jira] [Created] (KAFKA-7436) overriding auto.offset.reset to none for executor

2018-09-24 Thread Sanjay Kumar (JIRA)
Sanjay Kumar created KAFKA-7436: --- Summary: overriding auto.offset.reset to none for executor Key: KAFKA-7436 URL: https://issues.apache.org/jira/browse/KAFKA-7436 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-8563) Minor: Remove method call in netoworkSend

2019-06-18 Thread karan kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] karan kumar updated KAFKA-8563: --- Environment: Darwin WM-CXX 18.2.0 Darwin Kernel Version 18.2.0: Thu Dec 20 20:46:53 PST 2018;

[jira] [Created] (KAFKA-8563) Minor: Remove method call in netoworkSend

2019-06-18 Thread karan kumar (JIRA)
karan kumar created KAFKA-8563: -- Summary: Minor: Remove method call in netoworkSend Key: KAFKA-8563 URL: https://issues.apache.org/jira/browse/KAFKA-8563 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-8563) Minor: Remove method call in networkSend. Rely on java's vargs boxing/autoboxing

2019-06-19 Thread karan kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] karan kumar updated KAFKA-8563: --- Description: There was a 

[jira] [Commented] (KAFKA-8563) Minor: Remove method call in networkSend. Rely on java's vargs boxing/autoboxing

2019-06-19 Thread karan kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16867468#comment-16867468 ] karan kumar commented on KAFKA-8563: [https://github.com/apache/kafka/pull/6967] > Minor: Remove

[jira] [Updated] (KAFKA-8563) Minor: Remove method call in networkSend. Rely on java's vargs boxing/autoboxing

2019-06-19 Thread karan kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] karan kumar updated KAFKA-8563: --- Summary: Minor: Remove method call in networkSend. Rely on java's vargs boxing/autoboxing (was:

[jira] [Updated] (KAFKA-8563) Minor: Remove method call in networkSend. Rely on java's vargs boxing/autoboxing

2019-06-19 Thread karan kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] karan kumar updated KAFKA-8563: --- Description: There was a 

[jira] [Assigned] (KAFKA-8360) Docs do not mention RequestQueueSize JMX metric

2019-07-12 Thread Ankit Kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankit Kumar reassigned KAFKA-8360: -- Assignee: Ankit Kumar > Docs do not mention RequestQueueSize JMX metric >

[jira] [Commented] (KAFKA-4090) JVM runs into OOM if (Java) client uses a SSL port without setting the security protocol

2019-07-14 Thread Ankit Kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16884619#comment-16884619 ] Ankit Kumar commented on KAFKA-4090: Hey [~jaikiran], If no one is currently working on this. I

[jira] [Commented] (KAFKA-8573) kafka-topics.cmd OOM when connecting to a secure cluster without SSL properties

2019-07-14 Thread Ankit Kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16884620#comment-16884620 ] Ankit Kumar commented on KAFKA-8573: Hey [~heymjo], Thank you for creating this JIRA. I see the same

[jira] [Comment Edited] (KAFKA-7658) Add KStream#toTable to the Streams DSL

2019-09-11 Thread Aishwarya Pradeep Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16927881#comment-16927881 ] Aishwarya Pradeep Kumar edited comment on KAFKA-7658 at 9/11/19 6:18 PM:

[jira] [Commented] (KAFKA-7658) Add KStream#toTable to the Streams DSL

2019-09-11 Thread Aishwarya Pradeep Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16927881#comment-16927881 ] Aishwarya Pradeep Kumar commented on KAFKA-7658: I do not have access to create a KIP,

[jira] [Commented] (KAFKA-7658) Add KStream#toTable to the Streams DSL

2019-09-12 Thread Aishwarya Pradeep Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928582#comment-16928582 ] Aishwarya Pradeep Kumar commented on KAFKA-7658: [~mjsax] confluence id: ash26389. Thank

[jira] [Commented] (KAFKA-7658) Add KStream#toTable to the Streams DSL

2019-09-12 Thread Aishwarya Pradeep Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928814#comment-16928814 ] Aishwarya Pradeep Kumar commented on KAFKA-7658: Thank you!! KIP is created 

[jira] [Comment Edited] (KAFKA-7658) Add KStream#toTable to the Streams DSL

2019-09-12 Thread Aishwarya Pradeep Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928814#comment-16928814 ] Aishwarya Pradeep Kumar edited comment on KAFKA-7658 at 9/12/19 6:40 PM:

[jira] [Assigned] (KAFKA-8377) KTable#transformValue might lead to incorrect result in joins

2019-09-13 Thread Aishwarya Pradeep Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aishwarya Pradeep Kumar reassigned KAFKA-8377: -- Assignee: Aishwarya Pradeep Kumar > KTable#transformValue might lead

[jira] [Commented] (KAFKA-8377) KTable#transformValue might lead to incorrect result in joins

2019-09-13 Thread Aishwarya Pradeep Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16929245#comment-16929245 ] Aishwarya Pradeep Kumar commented on KAFKA-8377: [~Yohan123] - let me know if you are

[jira] [Commented] (KAFKA-7658) Add KStream#toTable to the Streams DSL

2019-09-10 Thread Aishwarya Pradeep Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16926817#comment-16926817 ] Aishwarya Pradeep Kumar commented on KAFKA-7658: Hi, I'm new to kafka contribution and

[jira] [Commented] (KAFKA-8377) KTable#transformValue might lead to incorrect result in joins

2019-09-16 Thread Aishwarya Pradeep Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16930635#comment-16930635 ] Aishwarya Pradeep Kumar commented on KAFKA-8377: [~mjsax], [~guozhang] based on my

[jira] [Commented] (KAFKA-8380) We can not create a topic, immediately write to it and then read.

2019-07-23 Thread Narendra Kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16890716#comment-16890716 ] Narendra Kumar commented on KAFKA-8380: --- I think this is because of the way you have written your

[jira] [Resolved] (KAFKA-8380) We can not create a topic, immediately write to it and then read.

2019-07-23 Thread Narendra Kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Narendra Kumar resolved KAFKA-8380. --- Resolution: Not A Problem > We can not create a topic, immediately write to it and then

[jira] [Commented] (KAFKA-8377) KTable#transformValue might lead to incorrect result in joins

2019-10-01 Thread Aishwarya Pradeep Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16942039#comment-16942039 ] Aishwarya Pradeep Kumar commented on KAFKA-8377: [~mjsax] thank you for the input, I'm

[jira] [Commented] (KAFKA-8327) Connection to Node2 was disconnected

2019-09-23 Thread Mohit Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16935604#comment-16935604 ] Mohit Kumar commented on KAFKA-8327: This has been solved by increasing the value of 

[jira] [Commented] (KAFKA-8377) KTable#transformValue might lead to incorrect result in joins

2019-09-24 Thread Aishwarya Pradeep Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16936910#comment-16936910 ] Aishwarya Pradeep Kumar commented on KAFKA-8377: {quote}But for some cases, if we force

[jira] [Assigned] (KAFKA-8402) bin/kafka-preferred-replica-election.sh fails if generated json is bigger than 1MB

2019-11-04 Thread Ankit Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankit Kumar reassigned KAFKA-8402: -- Assignee: Ankit Kumar > bin/kafka-preferred-replica-election.sh fails if generated json is

[jira] [Created] (KAFKA-9163) Re-assignment of Partition gets infinitely stuck "Still in progress" state

2019-11-07 Thread vikash kumar (Jira)
vikash kumar created KAFKA-9163: --- Summary: Re-assignment of Partition gets infinitely stuck "Still in progress" state Key: KAFKA-9163 URL: https://issues.apache.org/jira/browse/KAFKA-9163 Project:

[jira] [Assigned] (KAFKA-8573) kafka-topics.cmd OOM when connecting to a secure cluster without SSL properties

2019-10-17 Thread Ankit Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankit Kumar reassigned KAFKA-8573: -- Assignee: Ankit Kumar > kafka-topics.cmd OOM when connecting to a secure cluster without SSL

[jira] [Created] (KAFKA-9337) Simplifying standalone mm2-connect config

2019-12-27 Thread karan kumar (Jira)
karan kumar created KAFKA-9337: -- Summary: Simplifying standalone mm2-connect config Key: KAFKA-9337 URL: https://issues.apache.org/jira/browse/KAFKA-9337 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-5041) Kafka TestKit library

2020-02-26 Thread karan kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046268#comment-17046268 ] karan kumar commented on KAFKA-5041: [~ijuma] are you actively working on this? We have an internal

[jira] [Assigned] (KAFKA-9375) Add thread names to kafka connect threads

2020-01-19 Thread karan kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] karan kumar reassigned KAFKA-9375: -- Assignee: karan kumar > Add thread names to kafka connect threads >

[jira] [Updated] (KAFKA-9375) Add thread names to kafka connect threads

2020-01-07 Thread karan kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] karan kumar updated KAFKA-9375: --- Affects Version/s: (was: 2.3.1) Description: Taking stack dumps reveals that some

[jira] [Created] (KAFKA-9375) Add thread names to kafka connect threads

2020-01-07 Thread karan kumar (Jira)
karan kumar created KAFKA-9375: -- Summary: Add thread names to kafka connect threads Key: KAFKA-9375 URL: https://issues.apache.org/jira/browse/KAFKA-9375 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-9375) Add thread names to kafka connect threads

2020-01-07 Thread karan kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] karan kumar updated KAFKA-9375: --- Priority: Minor (was: Major) > Add thread names to kafka connect threads >

[jira] [Created] (KAFKA-9884) Unable to override some client properties in Mirror maker 2.0

2020-04-17 Thread Mithun Kumar (Jira)
Mithun Kumar created KAFKA-9884: --- Summary: Unable to override some client properties in Mirror maker 2.0 Key: KAFKA-9884 URL: https://issues.apache.org/jira/browse/KAFKA-9884 Project: Kafka

[jira] [Comment Edited] (KAFKA-9603) Number of open files keeps increasing in Streams application

2020-04-17 Thread Abhishek Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17085556#comment-17085556 ] Abhishek Kumar edited comment on KAFKA-9603 at 4/17/20, 8:44 AM: -

[jira] [Commented] (KAFKA-9440) Add ConsumerGroupCommand to delete static members

2020-09-03 Thread Sandeep Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17190223#comment-17190223 ] Sandeep Kumar commented on KAFKA-9440: -- [~hachikuji] [~bchen225242] Can you please review KIP

[jira] [Commented] (KAFKA-9440) Add ConsumerGroupCommand to delete static members

2020-09-02 Thread Sandeep Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17189158#comment-17189158 ] Sandeep Kumar commented on KAFKA-9440: -- h4. [@Boyang Chen 

[jira] [Assigned] (KAFKA-10072) Kafkaconsumer is configured with different clientid parameters to obtain different results

2020-08-31 Thread Ankit Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankit Kumar reassigned KAFKA-10072: --- Assignee: Ankit Kumar > Kafkaconsumer is configured with different clientid parameters to

[jira] [Commented] (KAFKA-10072) Kafkaconsumer is configured with different clientid parameters to obtain different results

2020-09-01 Thread Ankit Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17188254#comment-17188254 ] Ankit Kumar commented on KAFKA-10072: - Hey [~qq619618919], I was trying to replicate the issue, but

[jira] [Assigned] (KAFKA-9440) Add ConsumerGroupCommand to delete static members

2020-09-01 Thread Sandeep Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sandeep Kumar reassigned KAFKA-9440: Assignee: Sandeep Kumar (was: Mani Jindal) > Add ConsumerGroupCommand to delete static

[jira] [Commented] (KAFKA-9220) TimeoutException when using kafka-preferred-replica-election

2020-09-25 Thread Ankit Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201931#comment-17201931 ] Ankit Kumar commented on KAFKA-9220: Hey [~hores], Are you planning on working on it? If not, I can

[jira] [Assigned] (KAFKA-10460) ReplicaListValidator format checking is incomplete

2020-09-22 Thread Ankit Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankit Kumar reassigned KAFKA-10460: --- Assignee: Ankit Kumar > ReplicaListValidator format checking is incomplete >

[jira] [Assigned] (KAFKA-9075) Extend documentation for usage of GlobalKTable vs KTable

2020-09-23 Thread Ankit Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankit Kumar reassigned KAFKA-9075: -- Assignee: Ankit Kumar > Extend documentation for usage of GlobalKTable vs KTable >

[jira] [Commented] (KAFKA-9075) Extend documentation for usage of GlobalKTable vs KTable

2020-09-24 Thread Ankit Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201421#comment-17201421 ] Ankit Kumar commented on KAFKA-9075: Thank you [~mjsax], I have an idea about creating a

[jira] [Commented] (KAFKA-10460) ReplicaListValidator format checking is incomplete

2020-09-21 Thread Ankit Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17199494#comment-17199494 ] Ankit Kumar commented on KAFKA-10460: - Hey [~robinp-tw], Are you working on this? If not, I will be

[jira] [Comment Edited] (KAFKA-10273) Connect Converters should produce actionable error messages

2020-09-20 Thread Ankit Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17199182#comment-17199182 ] Ankit Kumar edited comment on KAFKA-10273 at 9/21/20, 5:58 AM: --- Hey

[jira] [Commented] (KAFKA-9075) Extend documentation for usage of GlobalKTable vs KTable

2020-09-20 Thread Ankit Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17199158#comment-17199158 ] Ankit Kumar commented on KAFKA-9075: Happy to pick this up, if no one else is working on this

[jira] [Commented] (KAFKA-10273) Connect Converters should produce actionable error messages

2020-09-20 Thread Ankit Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17199182#comment-17199182 ] Ankit Kumar commented on KAFKA-10273: - Hey [~gharris1727]/[~rhauch],   If no one is currently

[jira] [Assigned] (KAFKA-10760) In compacted topic with max.compaction.lag.ms, the segments are not rolled until new messages arrive

2020-12-14 Thread Brajesh Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brajesh Kumar reassigned KAFKA-10760: -- Assignee: Brajesh Kumar > In compacted topic with max.compaction.lag.ms, the

[jira] [Commented] (KAFKA-10760) In compacted topic with max.compaction.lag.ms, the segments are not rolled until new messages arrive

2020-12-14 Thread Brajesh Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17249315#comment-17249315 ] Brajesh Kumar commented on KAFKA-10760: [~junrao] Can I pick this up and reproduce the issue?

[jira] [Commented] (KAFKA-9892) Producer state snapshot needs to be forced to disk

2020-11-19 Thread Brajesh Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17235516#comment-17235516 ] Brajesh Kumar commented on KAFKA-9892: --- [~ijuma]Can you please help me with build on my CR ? >

[jira] [Assigned] (KAFKA-9892) Producer state snapshot needs to be forced to disk

2020-11-02 Thread Brajesh Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brajesh Kumar reassigned KAFKA-9892: - Assignee: Brajesh Kumar > Producer state snapshot needs to be forced to disk >

[jira] [Assigned] (KAFKA-9892) Producer state snapshot needs to be forced to disk

2020-11-02 Thread Brajesh Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brajesh Kumar reassigned KAFKA-9892: - Assignee: (was: Brajesh Kumar) > Producer state snapshot needs to be forced to

[jira] [Assigned] (KAFKA-9892) Producer state snapshot needs to be forced to disk

2020-11-02 Thread Brajesh Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brajesh Kumar reassigned KAFKA-9892: - Assignee: Brajesh Kumar > Producer state snapshot needs to be forced to disk >

[jira] [Commented] (KAFKA-9948) Gradle Issue

2020-10-29 Thread Brajesh Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17223044#comment-17223044 ] Brajesh Kumar commented on KAFKA-9948: --- [~dulvinw] Which command you are using to build kafka?

[jira] [Comment Edited] (KAFKA-9948) Gradle Issue

2020-10-29 Thread Brajesh Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17223044#comment-17223044 ] Brajesh Kumar edited comment on KAFKA-9948 at 10/29/20, 5:02 PM: --

[jira] [Commented] (KAFKA-9892) Producer state snapshot needs to be forced to disk

2020-10-29 Thread Brajesh Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17223070#comment-17223070 ] Brajesh Kumar commented on KAFKA-9892: --- [~junrao] [~ijuma] Can I pick this up please? It seems

[jira] [Comment Edited] (KAFKA-10373) Kafka Reassign Partition is stuck with Java OutOfMemory error

2020-10-29 Thread Brajesh Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17223041#comment-17223041 ] Brajesh Kumar edited comment on KAFKA-10373 at 10/29/20, 4:59 PM: --- Hi

[jira] [Commented] (KAFKA-10373) Kafka Reassign Partition is stuck with Java OutOfMemory error

2020-10-29 Thread Brajesh Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17223041#comment-17223041 ] Brajesh Kumar commented on KAFKA-10373: Hi What is your Environment configurations(Linux/MAC

[jira] [Commented] (KAFKA-5381) ERROR Uncaught exception in scheduled task 'delete-expired-consumer-offsets' (kafka.utils.KafkaScheduler)

2020-11-06 Thread Brajesh Kumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17227530#comment-17227530 ] Brajesh Kumar commented on KAFKA-5381: --- We have seen this issue with Kafka 2.3.1. Broker also

  1   2   >