[jira] [Commented] (KAFKA-2729) Cached zkVersion not equal to that in zookeeper, broker not recovering.

2019-04-23 Thread Alexander Binzberger (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16823858#comment-16823858 ] Alexander Binzberger commented on KAFKA-2729: - [~evildracula] In an older ver

[jira] [Commented] (KAFKA-6951) Implement offset expiration semantics for unsubscribed topics

2019-04-23 Thread Bart De Neuter (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16823930#comment-16823930 ] Bart De Neuter commented on KAFKA-6951: --- Is there a current workaround to delete th

[jira] [Created] (KAFKA-8278) MockConsumer.poll and MockConsumer.wakupe are both synchronized

2019-04-23 Thread Kevin (JIRA)
Kevin created KAFKA-8278: Summary: MockConsumer.poll and MockConsumer.wakupe are both synchronized Key: KAFKA-8278 URL: https://issues.apache.org/jira/browse/KAFKA-8278 Project: Kafka Issue Type: Bu

[jira] [Updated] (KAFKA-8278) MockConsumer.poll and MockConsumer.wakeup are both synchronized

2019-04-23 Thread Kevin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin updated KAFKA-8278: - Summary: MockConsumer.poll and MockConsumer.wakeup are both synchronized (was: MockConsumer.poll and MockConsume

[jira] [Created] (KAFKA-8279) Discrepancy around what SubscriptionState.allConsumed returns

2019-04-23 Thread Kevin (JIRA)
Kevin created KAFKA-8279: Summary: Discrepancy around what SubscriptionState.allConsumed returns Key: KAFKA-8279 URL: https://issues.apache.org/jira/browse/KAFKA-8279 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-8279) Discrepancy around what SubscriptionState.allConsumed returns

2019-04-23 Thread Kevin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin updated KAFKA-8279: - Description: Per [https://kafka.apache.org/22/javadoc/index.html?org/apache/kafka/streams/KafkaStreams.html], t

[jira] [Created] (KAFKA-8280) Flaky Test DynamicBrokerReconfigurationTest#testUncleanLeaderElectionEnable

2019-04-23 Thread John Roesler (JIRA)
John Roesler created KAFKA-8280: --- Summary: Flaky Test DynamicBrokerReconfigurationTest#testUncleanLeaderElectionEnable Key: KAFKA-8280 URL: https://issues.apache.org/jira/browse/KAFKA-8280 Project: Kafk

[jira] [Commented] (KAFKA-8274) Old Committed messages got replayed after Kafka cluster Restart

2019-04-23 Thread JIRA
[ https://issues.apache.org/jira/browse/KAFKA-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16824252#comment-16824252 ] Sönke Liebau commented on KAFKA-8274: - hi [~hrishi_dypim], can you add some more deta

[jira] [Commented] (KAFKA-6761) Reduce Kafka Streams Footprint

2019-04-23 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16824256#comment-16824256 ] Matthias J. Sax commented on KAFKA-6761: I am just wondering why this ticket was

[jira] [Commented] (KAFKA-5581) Avoid creating changelog topics for state stores that are materialized from a source topic

2019-04-23 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16824258#comment-16824258 ] Matthias J. Sax commented on KAFKA-5581: [~guozhang] I am wondering if this is a

[jira] [Commented] (KAFKA-8274) Old Committed messages got replayed after Kafka cluster Restart

2019-04-23 Thread Hrishikesh tiwary (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16824270#comment-16824270 ] Hrishikesh tiwary commented on KAFKA-8274: -- Was this a planned restart or did th

[jira] [Created] (KAFKA-8281) Kstream hung and doing nothing

2019-04-23 Thread Nitin Patidar (JIRA)
Nitin Patidar created KAFKA-8281: Summary: Kstream hung and doing nothing Key: KAFKA-8281 URL: https://issues.apache.org/jira/browse/KAFKA-8281 Project: Kafka Issue Type: Bug Rep

[jira] [Commented] (KAFKA-8204) Streams may flush state stores in the incorrect order

2019-04-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16824371#comment-16824371 ] ASF GitHub Bot commented on KAFKA-8204: --- vvcephei commented on pull request #6623:

[jira] [Commented] (KAFKA-7895) Ktable supress operator emitting more than one record for the same key per window

2019-04-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16824376#comment-16824376 ] ASF GitHub Bot commented on KAFKA-7895: --- bbejeck commented on pull request #6616: K

[jira] [Commented] (KAFKA-7895) Ktable supress operator emitting more than one record for the same key per window

2019-04-23 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16824382#comment-16824382 ] John Roesler commented on KAFKA-7895: - Update: this bugfix has been merged to trunk (

[jira] [Created] (KAFKA-8282) Missing JMX bandwidth quota metrics for Produce and Fetch

2019-04-23 Thread JMVM (JIRA)
JMVM created KAFKA-8282: --- Summary: Missing JMX bandwidth quota metrics for Produce and Fetch Key: KAFKA-8282 URL: https://issues.apache.org/jira/browse/KAFKA-8282 Project: Kafka Issue Type: Bug Aff

[jira] [Updated] (KAFKA-8282) Missing JMX bandwidth quota metrics for Produce and Fetch

2019-04-23 Thread JMVM (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JMVM updated KAFKA-8282: Attachment: Screen Shot 2019-04-23 at 20.59.21.png > Missing JMX bandwidth quota metrics for Produce and Fetch > --

[jira] [Updated] (KAFKA-8282) Missing JMX bandwidth quota metrics for Produce and Fetch

2019-04-23 Thread JMVM (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JMVM updated KAFKA-8282: Description: Recently I performed several *rolling upgrades following official steps* for our Kafka brokers *from

[jira] [Updated] (KAFKA-8282) Missing JMX bandwidth quota metrics for Produce and Fetch

2019-04-23 Thread JMVM (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JMVM updated KAFKA-8282: Description: Recently I performed several *rolling upgrades following official steps* for our Kafka brokers *from

[jira] [Created] (KAFKA-8283) Add additional test cases for the topic deletion state machine

2019-04-23 Thread Jason Gustafson (JIRA)
Jason Gustafson created KAFKA-8283: -- Summary: Add additional test cases for the topic deletion state machine Key: KAFKA-8283 URL: https://issues.apache.org/jira/browse/KAFKA-8283 Project: Kafka

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

2019-04-23 Thread Patrik Kleindl (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16824514#comment-16824514 ] Patrik Kleindl commented on KAFKA-5998: --- [~mjsax] If the state-cleaner ran and dele

[jira] [Updated] (KAFKA-8281) Kstream hung and doing nothing

2019-04-23 Thread Nitin Patidar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nitin Patidar updated KAFKA-8281: - Priority: Critical (was: Major) > Kstream hung and doing nothing >

[jira] [Commented] (KAFKA-8227) Missing Links in Duality of Streams and Tables section

2019-04-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16824587#comment-16824587 ] ASF GitHub Bot commented on KAFKA-8227: --- londoncalling commented on pull request #2

[jira] [Commented] (KAFKA-7996) KafkaStreams does not pass timeout when closing Producer

2019-04-23 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16824698#comment-16824698 ] Lee Dongjin commented on KAFKA-7996: [~bbejeck] [~mjsax] Sorry for the late reply. I

[jira] [Commented] (KAFKA-8204) Streams may flush state stores in the incorrect order

2019-04-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16824707#comment-16824707 ] ASF GitHub Bot commented on KAFKA-8204: --- guozhangwang commented on pull request #66

[jira] [Commented] (KAFKA-8236) Incorporate version control for Kafka Streams Application Reset

2019-04-23 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16824716#comment-16824716 ] Guozhang Wang commented on KAFKA-8236: -- In order to understand the scope of this pro

[jira] [Commented] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

2019-04-23 Thread Terence Yi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16824732#comment-16824732 ] Terence Yi commented on KAFKA-7500: --- What's the time schedule of MM2.    > MirrorMake

[jira] [Commented] (KAFKA-8227) Missing Links in Duality of Streams and Tables section

2019-04-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16824745#comment-16824745 ] ASF GitHub Bot commented on KAFKA-8227: --- londoncalling commented on pull request #6

[jira] [Commented] (KAFKA-7895) Ktable supress operator emitting more than one record for the same key per window

2019-04-23 Thread Kun Song (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16824757#comment-16824757 ] Kun Song commented on KAFKA-7895: - Thank you [~mjsax] for your kind suggesstion, and [~vv

[jira] [Commented] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

2019-04-23 Thread Ryanne Dolan (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16824791#comment-16824791 ] Ryanne Dolan commented on KAFKA-7500: - [~terence.yi] MM2 is currently being tested by

[jira] [Commented] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

2019-04-23 Thread Terence Yi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16824828#comment-16824828 ] Terence Yi commented on KAFKA-7500: --- That's great! Do you have a test case set for ref