[jira] [Commented] (KAFKA-8522) Tombstones can survive forever

2019-08-20 Thread Richard Yu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911942#comment-16911942 ] Richard Yu commented on KAFKA-8522: --- Alright, sounds good. > Tombstones can survive forever >

[jira] [Created] (KAFKA-8822) Remove CompletedFetch type from Fetcher

2019-08-20 Thread Sean Glover (Jira)
Sean Glover created KAFKA-8822: -- Summary: Remove CompletedFetch type from Fetcher Key: KAFKA-8822 URL: https://issues.apache.org/jira/browse/KAFKA-8822 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-8806) Kafka.poll spends significant amount of time in KafkaConsumer.updateAssignmentMetadataIfNeeded

2019-08-20 Thread Jira
[ https://issues.apache.org/jira/browse/KAFKA-8806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xavier Léauté updated KAFKA-8806: - Description: Comparing the performance profile of 2.2.0 and 2.3.0, we are seeing significant

[jira] [Updated] (KAFKA-8806) Kafka.poll spends significant amount of time in KafkaConsumer.updateAssignmentMetadataIfNeeded

2019-08-20 Thread Jira
[ https://issues.apache.org/jira/browse/KAFKA-8806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xavier Léauté updated KAFKA-8806: - Description: Comparing the performance profile of 2.2.0 and 2.3.0, we are seeing significant

[jira] [Updated] (KAFKA-7499) Extend ProductionExceptionHandler to cover serialization exceptions

2019-08-20 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7499: --- Labels: beginner kip newbie (was: beginner newbie) > Extend ProductionExceptionHandler to

[jira] [Updated] (KAFKA-7499) Extend ProductionExceptionHandler to cover serialization exceptions

2019-08-20 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7499: --- Description: In

[jira] [Updated] (KAFKA-8812) Rebalance Producers

2019-08-20 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8812: --- Summary: Rebalance Producers (was: Rebalance Producers - yes, I mean it ;-)) > Rebalance

[jira] [Commented] (KAFKA-8812) Rebalance Producers - yes, I mean it ;-)

2019-08-20 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911754#comment-16911754 ] Matthias J. Sax commented on KAFKA-8812: [~wdaehn] – I added you to the list of contributors and

[jira] [Updated] (KAFKA-8812) Rebalance Producers - yes, I mean it ;-)

2019-08-20 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8812: --- Description: [KIP-509:

[jira] [Assigned] (KAFKA-8812) Rebalance Producers - yes, I mean it ;-)

2019-08-20 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-8812: -- Assignee: Werner Daehn > Rebalance Producers - yes, I mean it ;-) >

[jira] [Reopened] (KAFKA-8812) Rebalance Producers - yes, I mean it ;-)

2019-08-20 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-8812: No need to close the ticket, as long as the KIP was not declined :) > Rebalance Producers -

[jira] [Updated] (KAFKA-8812) Rebalance Producers - yes, I mean it ;-)

2019-08-20 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8812: --- Labels: kip (was: ) > Rebalance Producers - yes, I mean it ;-) >

[jira] [Comment Edited] (KAFKA-8793) StickyTaskAssignor throws java.lang.ArithmeticException

2019-08-20 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911750#comment-16911750 ] Matthias J. Sax edited comment on KAFKA-8793 at 8/20/19 9:43 PM: - This is

[jira] [Commented] (KAFKA-8793) StickyTaskAssignor throws java.lang.ArithmeticException

2019-08-20 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911750#comment-16911750 ] Matthias J. Sax commented on KAFKA-8793: This is a weird issue. It seem that the computed

[jira] [Commented] (KAFKA-8802) ConcurrentSkipListMap shows performance regression in cache and in-memory store

2019-08-20 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911663#comment-16911663 ] Sophie Blee-Goldman commented on KAFKA-8802: Hi [~f2005...@gmail.com], I can't really give an

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

2019-08-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911651#comment-16911651 ] Bill Bejeck commented on KAFKA-8737: I tested this on trunk with an existing unit test and it failed

[jira] [Assigned] (KAFKA-8374) KafkaApis.handleLeaderAndIsrRequest not robust to ZooKeeper exceptions

2019-08-20 Thread Bob Barrett (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bob Barrett reassigned KAFKA-8374: -- Assignee: Bob Barrett > KafkaApis.handleLeaderAndIsrRequest not robust to ZooKeeper

[jira] [Updated] (KAFKA-8802) ConcurrentSkipListMap shows performance regression in cache and in-memory store

2019-08-20 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8802: --- Description: The use of ConcurrentSkipListMap in the cache and in-memory stores

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

2019-08-20 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911628#comment-16911628 ] Matthias J. Sax commented on KAFKA-8737: Does it only affect 1.0.x or also newer releases? >

[jira] [Created] (KAFKA-8821) Avoid pattern subscription to allow for stricter ACL settings

2019-08-20 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-8821: -- Summary: Avoid pattern subscription to allow for stricter ACL settings Key: KAFKA-8821 URL: https://issues.apache.org/jira/browse/KAFKA-8821 Project: Kafka

[jira] [Commented] (KAFKA-8345) Create an Administrative API for Replica Reassignment

2019-08-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911553#comment-16911553 ] ASF GitHub Bot commented on KAFKA-8345: --- stanislavkozlovski commented on pull request #7041:

[jira] [Commented] (KAFKA-8810) Add mechanism to detect topology mismatch between streams instances

2019-08-20 Thread Vinoth Chandar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911528#comment-16911528 ] Vinoth Chandar commented on KAFKA-8810: --- [~pkleindl] Interesting. I was thinking of just generating

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-08-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911429#comment-16911429 ] Bill Bejeck commented on KAFKA-8803: Thanks for clarifying! > Stream will not start due to

[jira] [Comment Edited] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-08-20 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911420#comment-16911420 ] Raman Gupta edited comment on KAFKA-8803 at 8/20/19 2:43 PM: - You're right, I

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-08-20 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911420#comment-16911420 ] Raman Gupta commented on KAFKA-8803: You're right, I had the incorrect issue reference. I meant issue

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-08-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911395#comment-16911395 ] Bill Bejeck commented on KAFKA-8803: Thanks, [~rocketraman] I'll take a look over the logs.   BTW

[jira] [Commented] (KAFKA-7248) Kafka creating topic with no leader. Issue started showing up after unkerberizing the cluster

2019-08-20 Thread Igor (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911303#comment-16911303 ] Igor commented on KAFKA-7248: - Hello, I have got the same problem after mass deleting topics, some of them

[jira] [Commented] (KAFKA-7898) ERROR Caught unexpected throwable (org.apache.zookeeper.ClientCnxn)

2019-08-20 Thread Dimo Velev (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911297#comment-16911297 ] Dimo Velev commented on KAFKA-7898: --- Are there any plans to fix that with 2.1.x? Last update has been

[jira] [Comment Edited] (KAFKA-8104) Consumer cannot rejoin to the group after rebalancing

2019-08-20 Thread Gregory Koshelev (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911182#comment-16911182 ] Gregory Koshelev edited comment on KAFKA-8104 at 8/20/19 10:14 AM: ---

[jira] [Comment Edited] (KAFKA-8104) Consumer cannot rejoin to the group after rebalancing

2019-08-20 Thread Gregory Koshelev (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911182#comment-16911182 ] Gregory Koshelev edited comment on KAFKA-8104 at 8/20/19 10:14 AM: ---

[jira] [Commented] (KAFKA-8104) Consumer cannot rejoin to the group after rebalancing

2019-08-20 Thread Gregory Koshelev (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911182#comment-16911182 ] Gregory Koshelev commented on KAFKA-8104: - [~guozhang], I found server.log (there are 3 brokers,

[jira] [Commented] (KAFKA-8755) Stand-by Task of an Optimized Source Table Does Not Write Anything to its State Store

2019-08-20 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911121#comment-16911121 ] Bruno Cadonna commented on KAFKA-8755: -- bq. In optimized standby since we use the topic in both

[jira] [Commented] (KAFKA-6361) Fast leader fail over can lead to log divergence between leader and follower

2019-08-20 Thread Stanislav Kozlovski (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911080#comment-16911080 ] Stanislav Kozlovski commented on KAFKA-6361: [~hachikuji] [~apovzner] does this affect every

[jira] [Comment Edited] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-08-20 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911022#comment-16911022 ] Raman Gupta edited comment on KAFKA-8803 at 8/20/19 6:07 AM: - [~bbejeck] I

[jira] [Comment Edited] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-08-20 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911022#comment-16911022 ] Raman Gupta edited comment on KAFKA-8803 at 8/20/19 6:06 AM: - [~bbejeck] I

[jira] [Comment Edited] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-08-20 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911022#comment-16911022 ] Raman Gupta edited comment on KAFKA-8803 at 8/20/19 6:06 AM: - [~bbejeck] I

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-08-20 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911022#comment-16911022 ] Raman Gupta commented on KAFKA-8803: [~bbejeck] I have attached the logs of all the broker processes,

[jira] [Updated] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-08-20 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta updated KAFKA-8803: --- Attachment: logs.txt.gz > Stream will not start due to TimeoutException: Timeout expired after >

[jira] [Updated] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

2019-08-20 Thread Raman Gupta (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raman Gupta updated KAFKA-8803: --- Description: One streams app is consistently failing at startup with the following exception:

[jira] [Commented] (KAFKA-8802) ConcurrentSkipListMap shows performance regression in cache and in-memory store

2019-08-20 Thread ANURAG SHARMA (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911021#comment-16911021 ] ANURAG SHARMA commented on KAFKA-8802: -- [~ableegoldman] Just curious if you could share what exactly