[jira] [Commented] (KAFKA-5825) Streams not processing when exactly once is set

2017-09-05 Thread Ryan Worsley (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154827#comment-16154827 ] Ryan Worsley commented on KAFKA-5825: - Thanks [~guozhang] I don't get any obvious streams issues

[jira] [Commented] (KAFKA-5843) Mx4jLoader.maybeLoad should only be executed if kafka_mx4jenable is set to true

2017-09-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154820#comment-16154820 ] ASF GitHub Bot commented on KAFKA-5843: --- GitHub user lindong28 opened a pull request:

[jira] [Created] (KAFKA-5843) Mx4jLoader.maybeLoad should only be executed if kafka_mx4jenable is set to true

2017-09-05 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-5843: --- Summary: Mx4jLoader.maybeLoad should only be executed if kafka_mx4jenable is set to true Key: KAFKA-5843 URL: https://issues.apache.org/jira/browse/KAFKA-5843 Project: Kafka

[jira] [Commented] (KAFKA-5358) Consumer perf tool should count rebalance time separately

2017-09-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154732#comment-16154732 ] ASF GitHub Bot commented on KAFKA-5358: --- Github user huxihx closed the pull request at:

[jira] [Created] (KAFKA-5842) QueryableStateIntegrationTest may fail with JDK 7

2017-09-05 Thread Ted Yu (JIRA)
Ted Yu created KAFKA-5842: - Summary: QueryableStateIntegrationTest may fail with JDK 7 Key: KAFKA-5842 URL: https://issues.apache.org/jira/browse/KAFKA-5842 Project: Kafka Issue Type: Test

[jira] [Commented] (KAFKA-5523) ReplayLogProducer not using the new Kafka consumer

2017-09-05 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154647#comment-16154647 ] Guozhang Wang commented on KAFKA-5523: -- Sounds good to me. > ReplayLogProducer not using the new

[jira] [Commented] (KAFKA-5825) Streams not processing when exactly once is set

2017-09-05 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154645#comment-16154645 ] Guozhang Wang commented on KAFKA-5825: -- [~ryanworsley] At the moment I cannot think of any causes on

[jira] [Commented] (KAFKA-5825) Streams not processing when exactly once is set

2017-09-05 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154644#comment-16154644 ] Guozhang Wang commented on KAFKA-5825: -- These DEBUG logs are normal, they did not indicate any issues

[jira] [Commented] (KAFKA-5597) Autogenerate Producer sender metrics

2017-09-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154639#comment-16154639 ] ASF GitHub Bot commented on KAFKA-5597: --- Github user asfgit closed the pull request at:

[jira] [Created] (KAFKA-5841) Open old index files with read-only permission

2017-09-05 Thread Jason Gustafson (JIRA)
Jason Gustafson created KAFKA-5841: -- Summary: Open old index files with read-only permission Key: KAFKA-5841 URL: https://issues.apache.org/jira/browse/KAFKA-5841 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-5840) TransactionsTest#testBasicTransactions sometimes hangs

2017-09-05 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5840: -- Summary: TransactionsTest#testBasicTransactions sometimes hangs (was: TransactionsTest#testBasicTransactions

[jira] [Commented] (KAFKA-5823) Update Docs

2017-09-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154590#comment-16154590 ] ASF GitHub Bot commented on KAFKA-5823: --- Github user asfgit closed the pull request at:

[jira] [Updated] (KAFKA-5840) TransactionsTest#testBasicTransactions hangs

2017-09-05 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5840: -- Description: While testing 0.11.0.1 RC0 , I found Here is part of the stack trace: {code} "Test worker" #20

[jira] [Updated] (KAFKA-5840) TransactionsTest#testBasicTransactions hangs

2017-09-05 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5840: -- Description: While testing 0.11.0.1 RC0 , I found TransactionsTest hanging. Here is part of the stack trace:

[jira] [Updated] (KAFKA-5840) TransactionsTest#testBasicTransactions hangs

2017-09-05 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5840: -- Attachment: 5840.stack > TransactionsTest#testBasicTransactions hangs >

[jira] [Created] (KAFKA-5840) TransactionsTest#testBasicTransactions hangs

2017-09-05 Thread Ted Yu (JIRA)
Ted Yu created KAFKA-5840: - Summary: TransactionsTest#testBasicTransactions hangs Key: KAFKA-5840 URL: https://issues.apache.org/jira/browse/KAFKA-5840 Project: Kafka Issue Type: Test

[jira] [Commented] (KAFKA-5837) ReassignPartitionsCommand fails if default throttle/timeout used

2017-09-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154569#comment-16154569 ] ASF GitHub Bot commented on KAFKA-5837: --- Github user asfgit closed the pull request at:

[jira] [Resolved] (KAFKA-5837) ReassignPartitionsCommand fails if default throttle/timeout used

2017-09-05 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-5837. --- Resolution: Fixed Issue resolved by pull request 3792

[jira] [Commented] (KAFKA-5603) Streams should not abort transaction when closing zombie task

2017-09-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154514#comment-16154514 ] ASF GitHub Bot commented on KAFKA-5603: --- Github user asfgit closed the pull request at:

[jira] [Updated] (KAFKA-5833) Reset thread interrupt state in case of InterruptedException

2017-09-05 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5833: - Labels: newbie++ (was: ) > Reset thread interrupt state in case of InterruptedException >

[jira] [Updated] (KAFKA-5541) Streams should not re-throw if suspending/closing task fails

2017-09-05 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5541: --- Issue Type: Sub-task (was: Bug) Parent: KAFKA-5156 > Streams should not re-throw if

[jira] [Commented] (KAFKA-5783) Implement KafkaPrincipalBuilder interface with support for SASL (KIP-189)

2017-09-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154345#comment-16154345 ] ASF GitHub Bot commented on KAFKA-5783: --- GitHub user hachikuji opened a pull request:

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

2017-09-05 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2729: --- Affects Version/s: 0.9.0.0 0.10.0.0 0.10.1.0

[jira] [Commented] (KAFKA-4819) Expose states of active tasks to public API

2017-09-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154319#comment-16154319 ] ASF GitHub Bot commented on KAFKA-4819: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-2984) KTable should send old values along with new values to downstreams

2017-09-05 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154267#comment-16154267 ] Matthias J. Sax commented on KAFKA-2984: What do you exactly mean by this? If you think about DSL

[jira] [Commented] (KAFKA-5825) Streams not processing when exactly once is set

2017-09-05 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154256#comment-16154256 ] Matthias J. Sax commented on KAFKA-5825: I am not sure atm. \cc [~hachikuji] [~apurva] [~guozhang]

[jira] [Updated] (KAFKA-5836) Kafka Streams - API for specifying internal stream name on join

2017-09-05 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5836: - Labels: api needs-kip (was: needs-kip) > Kafka Streams - API for specifying internal stream name

[jira] [Updated] (KAFKA-5836) Kafka Streams - API for specifying internal stream name on join

2017-09-05 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5836: - Component/s: streams > Kafka Streams - API for specifying internal stream name on join >

[jira] [Updated] (KAFKA-5559) Metrics should throw if two client registers with same ID

2017-09-05 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5559: --- Description: Currently, {{AppInfoParser}} only logs a WARN message when a bean is registered

[jira] [Commented] (KAFKA-5559) Metrics should throw if two client registers with same ID

2017-09-05 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154204#comment-16154204 ] Matthias J. Sax commented on KAFKA-5559: As discussed, I am closing this as "not an issue". We can

[jira] [Commented] (KAFKA-5559) Metrics should throw if two client registers with same ID

2017-09-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154199#comment-16154199 ] ASF GitHub Bot commented on KAFKA-5559: --- Github user mjsax closed the pull request at:

[jira] [Commented] (KAFKA-5016) Consumer hang in poll method while rebalancing is in progress

2017-09-05 Thread Geoffrey Stewart (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154137#comment-16154137 ] Geoffrey Stewart commented on KAFKA-5016: - Thanks for your repsonse [~hachikuji] The way you have

[jira] [Commented] (KAFKA-5838) Speed up running system tests in docker a bit

2017-09-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16154083#comment-16154083 ] ASF GitHub Bot commented on KAFKA-5838: --- GitHub user cmccabe opened a pull request:

[jira] [Created] (KAFKA-5838) Speed up running system tests in docker a bit

2017-09-05 Thread Colin P. McCabe (JIRA)
Colin P. McCabe created KAFKA-5838: -- Summary: Speed up running system tests in docker a bit Key: KAFKA-5838 URL: https://issues.apache.org/jira/browse/KAFKA-5838 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-5037) Infinite loop if all input topics are unknown at startup

2017-09-05 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16153928#comment-16153928 ] Michael Noll commented on KAFKA-5037: - Ping [~mjsax]: do we target this for 1.0.0? > Infinite loop if

[jira] [Updated] (KAFKA-5836) Kafka Streams - API for specifying internal stream name on join

2017-09-05 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5836: --- Affects Version/s: 0.11.0.0 > Kafka Streams - API for specifying internal stream name on join

[jira] [Updated] (KAFKA-5836) Kafka Streams - API for specifying internal stream name on join

2017-09-05 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5836: --- Labels: needs-kip (was: ) > Kafka Streams - API for specifying internal stream name on join

[jira] [Commented] (KAFKA-5837) ReassignPartitionsCommand fails if default throttle/timeout used

2017-09-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16153885#comment-16153885 ] ASF GitHub Bot commented on KAFKA-5837: --- GitHub user rajinisivaram opened a pull request:

[jira] [Created] (KAFKA-5837) ReassignPartitionsCommand fails if default throttle/timeout used

2017-09-05 Thread Rajini Sivaram (JIRA)
Rajini Sivaram created KAFKA-5837: - Summary: ReassignPartitionsCommand fails if default throttle/timeout used Key: KAFKA-5837 URL: https://issues.apache.org/jira/browse/KAFKA-5837 Project: Kafka

[jira] [Created] (KAFKA-5836) Kafka Streams - API for specifying internal stream name on join

2017-09-05 Thread JIRA
Lovro Pandžić created KAFKA-5836: Summary: Kafka Streams - API for specifying internal stream name on join Key: KAFKA-5836 URL: https://issues.apache.org/jira/browse/KAFKA-5836 Project: Kafka

[jira] [Commented] (KAFKA-4366) KafkaStreams.close() blocks indefinitely

2017-09-05 Thread Seweryn Habdank-Wojewodzki (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16153390#comment-16153390 ] Seweryn Habdank-Wojewodzki commented on KAFKA-4366: --- Questions: * If I will use

[jira] [Created] (KAFKA-5835) CommitFailedException message is misleading and cause is swallowed

2017-09-05 Thread Stevo Slavic (JIRA)
Stevo Slavic created KAFKA-5835: --- Summary: CommitFailedException message is misleading and cause is swallowed Key: KAFKA-5835 URL: https://issues.apache.org/jira/browse/KAFKA-5835 Project: Kafka

[jira] [Updated] (KAFKA-5545) Kafka Stream not able to successfully restart over new broker ip

2017-09-05 Thread Damian Guy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5545: -- Fix Version/s: (was: 0.11.0.1) (was: 1.0.0) > Kafka Stream not able to

[jira] [Resolved] (KAFKA-805) log.append() may fail with a compressed messageset containing no uncompressed messages

2017-09-05 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-805. - Resolution: Fixed Not able to reproduce the issue. looks like this got fixed in newer versions. >