[jira] [Updated] (KAFKA-7632) Add producer option to adjust compression level

2018-11-16 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin updated KAFKA-7632: --- Description: The compression level for ZSTD is currently set to use the default level (3), which is

[jira] [Updated] (KAFKA-7632) Add option to kafka broker config to adjust compression level for zstd

2018-11-16 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin updated KAFKA-7632: --- Description: The compression level for ZSTD is currently set to use the default level (3), which is

[jira] [Updated] (KAFKA-7632) Add producer option to adjust compression level

2018-11-16 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin updated KAFKA-7632: --- Summary: Add producer option to adjust compression level (was: Add option to kafka broker config to

[jira] [Updated] (KAFKA-7632) Add option to kafka broker config to adjust compression level for zstd

2018-11-16 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin updated KAFKA-7632: --- Description: The compression level for ZSTD is currently set to use the default level (3), which is

[jira] [Updated] (KAFKA-7632) Add option to kafka broker config to adjust compression level for zstd

2018-11-16 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin updated KAFKA-7632: --- Fix Version/s: (was: 2.1.0) 2.2.0 > Add option to kafka broker config to

[jira] [Updated] (KAFKA-7632) Add option to kafka broker config to adjust compression level for zstd

2018-11-16 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin updated KAFKA-7632: --- Component/s: (was: core) clients > Add option to kafka broker config to adjust

[jira] [Updated] (KAFKA-7632) Add option to kafka broker config to adjust compression level for zstd

2018-11-16 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin updated KAFKA-7632: --- Priority: Major (was: Trivial) > Add option to kafka broker config to adjust compression level for

[jira] [Assigned] (KAFKA-7632) Add option to kafka broker config to adjust compression level for zstd

2018-11-16 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin reassigned KAFKA-7632: -- Assignee: Lee Dongjin > Add option to kafka broker config to adjust compression level for

[jira] [Updated] (KAFKA-7647) Flaky test LogCleanerParameterizedIntegrationTest.testCleansCombinedCompactAndDeleteTopic

2018-11-16 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7647: Description: {code} kafka.log.LogCleanerParameterizedIntegrationTest >

[jira] [Updated] (KAFKA-7578) Kafka streams: add possibility to choose multiple output topics

2018-11-16 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-7578: - Labels: needs-kip user-experience (was: needs-kip) > Kafka streams: add possibility to choose

[jira] [Commented] (KAFKA-7646) Flaky test SaslOAuthBearerSslEndToEndAuthorizationTest.testNoConsumeWithDescribeAclViaSubscribe

2018-11-16 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690174#comment-16690174 ] Dong Lin commented on KAFKA-7646: - This issue is not captured by the automatic test runs in

[jira] [Commented] (KAFKA-7577) Semantics of Table-Table Join with Null Message Are Incorrect

2018-11-16 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690175#comment-16690175 ] Guozhang Wang commented on KAFKA-7577: -- Hi [~dthomas-trimble], any luck trying to reproduce the

[jira] [Updated] (KAFKA-7651) Flaky test SaslSslAdminClientIntegrationTest.testMinimumRequestTimeouts

2018-11-16 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7651: Issue Type: Sub-task (was: Task) Parent: KAFKA-7645 > Flaky test

[jira] [Commented] (KAFKA-7651) Flaky test SaslSslAdminClientIntegrationTest.testMinimumRequestTimeouts

2018-11-16 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690173#comment-16690173 ] Dong Lin commented on KAFKA-7651: - The test failure is related to SSL handshake. In general SSL handshake

[jira] [Issue Comment Deleted] (KAFKA-7312) Transient failure in kafka.api.AdminClientIntegrationTest.testMinimumRequestTimeouts

2018-11-16 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7312: Comment: was deleted (was: Here is another stacktrace from

[jira] [Updated] (KAFKA-7312) Transient failure in kafka.api.AdminClientIntegrationTest.testMinimumRequestTimeouts

2018-11-16 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7312: Issue Type: Bug (was: Sub-task) Parent: (was: KAFKA-7645) > Transient failure in >

[jira] [Created] (KAFKA-7651) Flaky test SaslSslAdminClientIntegrationTest.testMinimumRequestTimeouts

2018-11-16 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-7651: --- Summary: Flaky test SaslSslAdminClientIntegrationTest.testMinimumRequestTimeouts Key: KAFKA-7651 URL: https://issues.apache.org/jira/browse/KAFKA-7651 Project: Kafka

[jira] [Comment Edited] (KAFKA-7312) Transient failure in kafka.api.AdminClientIntegrationTest.testMinimumRequestTimeouts

2018-11-16 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690150#comment-16690150 ] Dong Lin edited comment on KAFKA-7312 at 11/17/18 12:36 AM: Here is another

[jira] [Commented] (KAFKA-7649) Flaky test SslEndToEndAuthorizationTest.testNoProduceWithDescribeAcl

2018-11-16 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690168#comment-16690168 ] Dong Lin commented on KAFKA-7649: - The there is error in the log that says "No JAAS configuration section

[jira] [Commented] (KAFKA-7634) Punctuate not being called with merge() and/or outerJoin()

2018-11-16 Thread Eugen Feller (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690159#comment-16690159 ] Eugen Feller commented on KAFKA-7634: - Sure, let me try what I can do. Code looks like this:  

[jira] [Commented] (KAFKA-7402) Kafka Streams should implement AutoCloseable where appropriate

2018-11-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690153#comment-16690153 ] ASF GitHub Bot commented on KAFKA-7402: --- cmccabe closed pull request #5839: KAFKA-7402: Kafka

[jira] [Commented] (KAFKA-7531) NPE NullPointerException at TransactionCoordinator handleEndTransaction

2018-11-16 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690155#comment-16690155 ] Guozhang Wang commented on KAFKA-7531: -- [~spuzon] I cannot recall there is a config named

[jira] [Commented] (KAFKA-7312) Transient failure in kafka.api.AdminClientIntegrationTest.testMinimumRequestTimeouts

2018-11-16 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690150#comment-16690150 ] Dong Lin commented on KAFKA-7312: - Here is another stacktrace: {code} Error Message

[jira] [Created] (KAFKA-7650) make "auto.create.topics.enable" dynamically configurable.

2018-11-16 Thread xiongqi wu (JIRA)
xiongqi wu created KAFKA-7650: - Summary: make "auto.create.topics.enable" dynamically configurable. Key: KAFKA-7650 URL: https://issues.apache.org/jira/browse/KAFKA-7650 Project: Kafka Issue

[jira] [Commented] (KAFKA-7648) Flaky test DeleteTopicsRequestTest.testValidDeleteTopicRequests

2018-11-16 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690140#comment-16690140 ] Dong Lin commented on KAFKA-7648: - Currently TestUtils.createTopic(...) will re-send znode creation

[jira] [Comment Edited] (KAFKA-7648) Flaky test DeleteTopicsRequestTest.testValidDeleteTopicRequests

2018-11-16 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690140#comment-16690140 ] Dong Lin edited comment on KAFKA-7648 at 11/16/18 11:47 PM: Currently

[jira] [Updated] (KAFKA-7622) Add findSessions functionality to ReadOnlySessionStore

2018-11-16 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-7622: - Labels: needs-kip user-experience (was: needs-kip) > Add findSessions functionality to

[jira] [Commented] (KAFKA-7628) KafkaStream is not closing

2018-11-16 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690138#comment-16690138 ] Guozhang Wang commented on KAFKA-7628: -- Hmm.. in this case the state should not be transit to

[jira] [Comment Edited] (KAFKA-7486) Flaky test `DeleteTopicTest.testAddPartitionDuringDeleteTopic`

2018-11-16 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690115#comment-16690115 ] Dong Lin edited comment on KAFKA-7486 at 11/16/18 11:13 PM: The test calls

[jira] [Commented] (KAFKA-7446) Better error message to explain the upper limit of TimeWindow

2018-11-16 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690134#comment-16690134 ] Guozhang Wang commented on KAFKA-7446: -- [~mrsrinivas] Please feel free to submit the PR. > Better

[jira] [Commented] (KAFKA-7541) Transient Failure: kafka.server.DynamicBrokerReconfigurationTest.testUncleanLeaderElectionEnable

2018-11-16 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690130#comment-16690130 ] Dong Lin commented on KAFKA-7541: - According to the source code

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

2018-11-16 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690118#comment-16690118 ] Guozhang Wang commented on KAFKA-6567: -- [~Samuel Hawker] Sure, go ahead and submit the PR :) >

[jira] [Commented] (KAFKA-7634) Punctuate not being called with merge() and/or outerJoin()

2018-11-16 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690116#comment-16690116 ] Guozhang Wang commented on KAFKA-7634: -- Could you share your code snippet around the punctuation

[jira] [Commented] (KAFKA-7486) Flaky test `DeleteTopicTest.testAddPartitionDuringDeleteTopic`

2018-11-16 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690115#comment-16690115 ] Dong Lin commented on KAFKA-7486: - The test calls `AdminUtils.addPartitions` to add partition to the

[jira] [Updated] (KAFKA-7541) Transient Failure: kafka.server.DynamicBrokerReconfigurationTest.testUncleanLeaderElectionEnable

2018-11-16 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7541: Issue Type: Sub-task (was: Bug) Parent: KAFKA-7645 > Transient Failure: >

[jira] [Created] (KAFKA-7646) Flaky test SaslOAuthBearerSslEndToEndAuthorizationTest.testNoConsumeWithDescribeAclViaSubscribe

2018-11-16 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-7646: --- Summary: Flaky test SaslOAuthBearerSslEndToEndAuthorizationTest.testNoConsumeWithDescribeAclViaSubscribe Key: KAFKA-7646 URL: https://issues.apache.org/jira/browse/KAFKA-7646

[jira] [Updated] (KAFKA-7649) Flaky test SslEndToEndAuthorizationTest.testNoProduceWithDescribeAcl

2018-11-16 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7649: Issue Type: Sub-task (was: Task) Parent: KAFKA-7645 > Flaky test

[jira] [Created] (KAFKA-7649) Flaky test SslEndToEndAuthorizationTest.testNoProduceWithDescribeAcl

2018-11-16 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-7649: --- Summary: Flaky test SslEndToEndAuthorizationTest.testNoProduceWithDescribeAcl Key: KAFKA-7649 URL: https://issues.apache.org/jira/browse/KAFKA-7649 Project: Kafka

[jira] [Updated] (KAFKA-7648) Flaky test DeleteTopicsRequestTest.testValidDeleteTopicRequests

2018-11-16 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7648: Description: Observed in

[jira] [Updated] (KAFKA-7312) Transient failure in kafka.api.AdminClientIntegrationTest.testMinimumRequestTimeouts

2018-11-16 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7312: Issue Type: Sub-task (was: Improvement) Parent: KAFKA-7645 > Transient failure in >

[jira] [Created] (KAFKA-7648) Flaky test DeleteTopicsRequestTest.testValidDeleteTopicRequests

2018-11-16 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-7648: --- Summary: Flaky test DeleteTopicsRequestTest.testValidDeleteTopicRequests Key: KAFKA-7648 URL: https://issues.apache.org/jira/browse/KAFKA-7648 Project: Kafka Issue

[jira] [Updated] (KAFKA-7648) Flaky test DeleteTopicsRequestTest.testValidDeleteTopicRequests

2018-11-16 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7648: Issue Type: Sub-task (was: Task) Parent: KAFKA-7645 > Flaky test

[jira] [Updated] (KAFKA-7647) Flaky test LogCleanerParameterizedIntegrationTest.testCleansCombinedCompactAndDeleteTopic

2018-11-16 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7647: Issue Type: Sub-task (was: Task) Parent: KAFKA-7645 > Flaky test >

[jira] [Created] (KAFKA-7647) Flaky test LogCleanerParameterizedIntegrationTest.testCleansCombinedCompactAndDeleteTopic

2018-11-16 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-7647: --- Summary: Flaky test LogCleanerParameterizedIntegrationTest.testCleansCombinedCompactAndDeleteTopic Key: KAFKA-7647 URL: https://issues.apache.org/jira/browse/KAFKA-7647

[jira] [Updated] (KAFKA-7646) Flaky test SaslOAuthBearerSslEndToEndAuthorizationTest.testNoConsumeWithDescribeAclViaSubscribe

2018-11-16 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7646: Issue Type: Sub-task (was: Task) Parent: KAFKA-7645 > Flaky test >

[jira] [Updated] (KAFKA-7486) Flaky test `DeleteTopicTest.testAddPartitionDuringDeleteTopic`

2018-11-16 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7486: Issue Type: Sub-task (was: Bug) Parent: KAFKA-7645 > Flaky test

[jira] [Created] (KAFKA-7645) Fix flaky unit test for 2.1 branch

2018-11-16 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-7645: --- Summary: Fix flaky unit test for 2.1 branch Key: KAFKA-7645 URL: https://issues.apache.org/jira/browse/KAFKA-7645 Project: Kafka Issue Type: Task

[jira] [Comment Edited] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker

2018-11-16 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690102#comment-16690102 ] Boyang Chen edited comment on KAFKA-7641 at 11/16/18 10:50 PM: --- [~enether]

[jira] [Commented] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker

2018-11-16 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690102#comment-16690102 ] Boyang Chen commented on KAFKA-7641: [~enether] Thanks! I think we need to propose two KIPs here: 1.

[jira] [Commented] (KAFKA-7486) Flaky test `DeleteTopicTest.testAddPartitionDuringDeleteTopic`

2018-11-16 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690099#comment-16690099 ] Dong Lin commented on KAFKA-7486: - Hey [~chia7712], I think [~hachikuji] probably missed your message. I

[jira] [Created] (KAFKA-7644) Worker Re balance enhancements

2018-11-16 Thread satya (JIRA)
satya created KAFKA-7644: Summary: Worker Re balance enhancements Key: KAFKA-7644 URL: https://issues.apache.org/jira/browse/KAFKA-7644 Project: Kafka Issue Type: Improvement Components:

[jira] [Commented] (KAFKA-7634) Punctuate not being called with merge() and/or outerJoin()

2018-11-16 Thread Eugen Feller (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690046#comment-16690046 ] Eugen Feller commented on KAFKA-7634: - [~guozhang] In the meantime I found that if I materialize the

[jira] [Created] (KAFKA-7642) Kafka Connect - graceful shutdown of distributed worker

2018-11-16 Thread satya (JIRA)
satya created KAFKA-7642: Summary: Kafka Connect - graceful shutdown of distributed worker Key: KAFKA-7642 URL: https://issues.apache.org/jira/browse/KAFKA-7642 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-5946) Give connector method parameter better name

2018-11-16 Thread Samuel Hawker (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690043#comment-16690043 ] Samuel Hawker commented on KAFKA-5946: -- Hi, I notice this has not seen any activity in many months,

[jira] [Created] (KAFKA-7643) Connectors do not unload even when tasks fail in kafka connect

2018-11-16 Thread satya (JIRA)
satya created KAFKA-7643: Summary: Connectors do not unload even when tasks fail in kafka connect Key: KAFKA-7643 URL: https://issues.apache.org/jira/browse/KAFKA-7643 Project: Kafka Issue Type:

[jira] [Comment Edited] (KAFKA-5946) Give connector method parameter better name

2018-11-16 Thread Samuel Hawker (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690043#comment-16690043 ] Samuel Hawker edited comment on KAFKA-5946 at 11/16/18 9:58 PM: Hi, I

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

2018-11-16 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690040#comment-16690040 ] John Roesler commented on KAFKA-6567: - This seems fine to me. Unless [~sawyna] wants to protest, I'd

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

2018-11-16 Thread Samuel Hawker (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689983#comment-16689983 ] Samuel Hawker edited comment on KAFKA-6567 at 11/16/18 9:38 PM: Hi, I

[jira] [Commented] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker

2018-11-16 Thread Stanislav Kozlovski (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690013#comment-16690013 ] Stanislav Kozlovski commented on KAFKA-7641: Thanks for opening the ticket [~bchen225242] . 

[jira] [Assigned] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker

2018-11-16 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-7641: -- Assignee: Boyang Chen > Add `consumer.group.max.size` to cap consumer metadata size on broker

[jira] [Commented] (KAFKA-7634) Punctuate not being called with merge() and/or outerJoin()

2018-11-16 Thread Eugen Feller (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690001#comment-16690001 ] Eugen Feller commented on KAFKA-7634: - Hi [~guozhang] Thanks a lot for your quick reply. I will give

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

2018-11-16 Thread Samuel Hawker (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689983#comment-16689983 ] Samuel Hawker commented on KAFKA-6567: -- Hi, I notice this has not seen any activity in many months,

[jira] [Commented] (KAFKA-4453) add request prioritization

2018-11-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689957#comment-16689957 ] ASF GitHub Bot commented on KAFKA-4453: --- gitlw closed pull request #5783: KAFKA-4453: Separating

[jira] [Updated] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker

2018-11-16 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-7641: --- Description: In the JIRA discussion https://issues.apache.org/jira/browse/KAFKA-7610, Jason

[jira] [Commented] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker

2018-11-16 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689925#comment-16689925 ] Boyang Chen commented on KAFKA-7641: [~hachikuji] [~enether] > Add `consumer.group.max.size` to cap

[jira] [Updated] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker

2018-11-16 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-7641: --- Description: In the JIRA discussion https://issues.apache.org/jira/browse/KAFKA-7610, Jason

[jira] [Updated] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker

2018-11-16 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-7641: --- Summary: Add `consumer.group.max.size` to cap consumer metadata size on broker (was: Add

[jira] [Created] (KAFKA-7641) Add `group.max.size` to cap group metadata on broker

2018-11-16 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-7641: -- Summary: Add `group.max.size` to cap group metadata on broker Key: KAFKA-7641 URL: https://issues.apache.org/jira/browse/KAFKA-7641 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-7610) Detect consumer failures in initial JoinGroup

2018-11-16 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689916#comment-16689916 ] Boyang Chen commented on KAFKA-7610: Sounds good Jason! I think combining `group.max.size` and member

[jira] [Created] (KAFKA-7640) Kafka stream interactive query not returning data when state is backed by rocksdb

2018-11-16 Thread hitesh gollahalli bachanna (JIRA)
hitesh gollahalli bachanna created KAFKA-7640: - Summary: Kafka stream interactive query not returning data when state is backed by rocksdb Key: KAFKA-7640 URL:

[jira] [Commented] (KAFKA-7610) Detect consumer failures in initial JoinGroup

2018-11-16 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689866#comment-16689866 ] Jason Gustafson commented on KAFKA-7610: For some background, the case we observed in practice

[jira] [Commented] (KAFKA-7595) Kafka Streams: KTrable to KTable join introduces duplicates in downstream KTable

2018-11-16 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689838#comment-16689838 ] Matthias J. Sax commented on KAFKA-7595: Glad it works. Thanks for confirmation! > Kafka

[jira] [Commented] (KAFKA-4453) add request prioritization

2018-11-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689832#comment-16689832 ] ASF GitHub Bot commented on KAFKA-4453: --- MayureshGharat opened a new pull request #5921: KAFKA-4453

[jira] [Commented] (KAFKA-7639) Read one request at a time from socket to reduce broker memory usage

2018-11-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689730#comment-16689730 ] ASF GitHub Bot commented on KAFKA-7639: --- rajinisivaram opened a new pull request #5920: [DO NOT

[jira] [Commented] (KAFKA-7637) Error while writing to checkpoint file due to too many open files

2018-11-16 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689570#comment-16689570 ] Ismael Juma commented on KAFKA-7637: Thanks for the report. 65k is generally low for Kafka. It would

[jira] [Updated] (KAFKA-7635) FetcherThread stops processing after "Error processing data for partition"

2018-11-16 Thread Steven Aerts (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Aerts updated KAFKA-7635: Description: After disabling unclean leader leader again after recovery of a situation where we

[jira] [Created] (KAFKA-7638) Trogdor - Support mass task creation endpoint

2018-11-16 Thread Stanislav Kozlovski (JIRA)
Stanislav Kozlovski created KAFKA-7638: -- Summary: Trogdor - Support mass task creation endpoint Key: KAFKA-7638 URL: https://issues.apache.org/jira/browse/KAFKA-7638 Project: Kafka

[jira] [Updated] (KAFKA-7637) Error while writing to checkpoint file due to too many open files

2018-11-16 Thread Sander van Loo (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sander van Loo updated KAFKA-7637: -- Summary: Error while writing to checkpoint file due to too many open files (was: ERROR Error

[jira] [Updated] (KAFKA-7636) Allow consumer to update maxPollRecords value

2018-11-16 Thread Kcirtap Seven (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kcirtap Seven updated KAFKA-7636: - Labels: pull-request-available (was: ) Description: Hi, We have two use cases where

[jira] [Commented] (KAFKA-7636) Allow consumer to update maxPollRecords value

2018-11-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689465#comment-16689465 ] ASF GitHub Bot commented on KAFKA-7636: --- kcirtap7 opened a new pull request #5919: KAFKA-7636:

[jira] [Created] (KAFKA-7636) Allow consumer to update maxPollRecords value

2018-11-16 Thread Kcirtap Seven (JIRA)
Kcirtap Seven created KAFKA-7636: Summary: Allow consumer to update maxPollRecords value Key: KAFKA-7636 URL: https://issues.apache.org/jira/browse/KAFKA-7636 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-7565) NPE in KafkaConsumer

2018-11-16 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-7565. --- Resolution: Duplicate Fix Version/s: (was: 2.2.0) [~avakhrenev] Thanks for

[jira] [Commented] (KAFKA-7054) Kafka describe command should throw topic doesn't exist exception.

2018-11-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689311#comment-16689311 ] ASF GitHub Bot commented on KAFKA-7054: --- ManoharVanam opened a new pull request #5211: [KAFKA-7054]

[jira] [Resolved] (KAFKA-7576) Dynamic update of replica fetcher threads may fail to start/close fetchers

2018-11-16 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-7576. --- Resolution: Fixed Reviewer: Jason Gustafson > Dynamic update of replica fetcher

[jira] [Commented] (KAFKA-7054) Kafka describe command should throw topic doesn't exist exception.

2018-11-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689282#comment-16689282 ] ASF GitHub Bot commented on KAFKA-7054: --- ManoharVanam closed pull request #5211: [KAFKA-7054] Kafka

[jira] [Commented] (KAFKA-7635) FetcherThread stops processing after "Error processing data for partition"

2018-11-16 Thread Steven Aerts (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689278#comment-16689278 ] Steven Aerts commented on KAFKA-7635: - Similar but focusses on a specific issue. > FetcherThread

[jira] [Commented] (KAFKA-7280) ConcurrentModificationException in FetchSessionHandler in heartbeat thread

2018-11-16 Thread Sachin Upadhyay (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689269#comment-16689269 ] Sachin Upadhyay commented on KAFKA-7280: [~rsivaram] Thanks for the detailed answers. [~ijuma] I

[jira] [Commented] (KAFKA-7565) NPE in KafkaConsumer

2018-11-16 Thread Alexey Vakhrenev (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689243#comment-16689243 ] Alexey Vakhrenev commented on KAFKA-7565: - [~rsivaram], [~ijuma] the issue seems to be fixed in

[jira] [Created] (KAFKA-7635) FetcherThread stops processing after "Error processing data for partition"

2018-11-16 Thread Steven Aerts (JIRA)
Steven Aerts created KAFKA-7635: --- Summary: FetcherThread stops processing after "Error processing data for partition" Key: KAFKA-7635 URL: https://issues.apache.org/jira/browse/KAFKA-7635 Project:

[jira] [Resolved] (KAFKA-6774) Improve default groupId behavior in consumer

2018-11-16 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6774. Resolution: Fixed > Improve default groupId behavior in consumer >

[jira] [Commented] (KAFKA-6774) Improve default groupId behavior in consumer

2018-11-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689175#comment-16689175 ] ASF GitHub Bot commented on KAFKA-6774: --- hachikuji closed pull request #5877: KAFKA-6774: Improve