[jira] [Commented] (KAFKA-3887) StreamBounceTest.test_bounce and StreamSmokeTest.test_streams failing

[ https://issues.apache.org/jira/browse/KAFKA-3887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15369420#comment-15369420 ] ASF GitHub Bot commented on KAFKA-3887: --- GitHub user guozhangwang opened a pull requ

[GitHub] kafka pull request #1604: KAFKA-3887 Follow-up: add unit test for null check...

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/1604 KAFKA-3887 Follow-up: add unit test for null checking in KTable aggregates Also made a pass over the streams unit tests, with the following changes: 1. Removed three integration tests a

[jira] [Commented] (KAFKA-1429) Yet another deadlock in controller shutdown

[ https://issues.apache.org/jira/browse/KAFKA-1429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15369380#comment-15369380 ] ASF GitHub Bot commented on KAFKA-1429: --- GitHub user pengwei-li opened a pull reques

[GitHub] kafka pull request #1603: KAFKA-1429: Yet another deadlock in controller shu...

GitHub user pengwei-li opened a pull request: https://github.com/apache/kafka/pull/1603 KAFKA-1429: Yet another deadlock in controller shutdown Author: pengwei Reviewers: NA You can merge this pull request into a Git repository by running: $ git pull https://github

[jira] [Commented] (KAFKA-3943) ConfigDef should support a builder pattern.

[ https://issues.apache.org/jira/browse/KAFKA-3943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15369347#comment-15369347 ] ASF GitHub Bot commented on KAFKA-3943: --- GitHub user jcustenborder opened a pull req

[GitHub] kafka pull request #1602: KAFKA-3943 - ConfigDef with Builder pattern

GitHub user jcustenborder opened a pull request: https://github.com/apache/kafka/pull/1602 KAFKA-3943 - ConfigDef with Builder pattern Added Builder class and define() method with no arguments. Added testcase validating the ConfigDef using the current implementation against the new

Re: Avoid recreating reassign partition path in zk if it is already deleted

For the benefit of the future readers, a simple workaround for this issue is to: # change the controller to a non-existing broker, # delete the current assignment from zk, and # then change the controller to an existent broker Maysam On Wed, May 11, 2016 at 5:24 PM, Maysam Yabandeh wrote: > Hi

[jira] [Created] (KAFKA-3944) After the broker restart, fetchers stopped due to a delayed controlled shutdown message

Maysam Yabandeh created KAFKA-3944: -- Summary: After the broker restart, fetchers stopped due to a delayed controlled shutdown message Key: KAFKA-3944 URL: https://issues.apache.org/jira/browse/KAFKA-3944

[jira] [Created] (KAFKA-3943) ConfigDef should support a builder pattern.

Jeremy Custenborder created KAFKA-3943: -- Summary: ConfigDef should support a builder pattern. Key: KAFKA-3943 URL: https://issues.apache.org/jira/browse/KAFKA-3943 Project: Kafka Issue T

[jira] [Resolved] (KAFKA-3882) Integration failures on low-end machines

[ https://issues.apache.org/jira/browse/KAFKA-3882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3882. -- Resolution: Not A Bug I found out this is actually due to an issue on my local machine. > Integ

[jira] [Comment Edited] (KAFKA-3101) Optimize Aggregation Outputs

[ https://issues.apache.org/jira/browse/KAFKA-3101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15369257#comment-15369257 ] Bill Bejeck edited comment on KAFKA-3101 at 7/9/16 7:26 PM: [~

[jira] [Commented] (KAFKA-3101) Optimize Aggregation Outputs

[ https://issues.apache.org/jira/browse/KAFKA-3101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15369257#comment-15369257 ] Bill Bejeck commented on KAFKA-3101: [~enothereska] none actually, a misunderstanding

[jira] [Commented] (KAFKA-3905) remove null from subscribed topics in KafkaConsumer#subscribe

[ https://issues.apache.org/jira/browse/KAFKA-3905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15369206#comment-15369206 ] ASF GitHub Bot commented on KAFKA-3905: --- GitHub user rekhajoshm opened a pull reques

[GitHub] kafka pull request #1601: KAFKA-3905; Handle invalid collection of topics, p...

GitHub user rekhajoshm opened a pull request: https://github.com/apache/kafka/pull/1601 KAFKA-3905; Handle invalid collection of topics, patterns on subscription for list of topics, with patterns, and with assignments KAFKA-3905: Handling null/empty topics and collections, patterns

[jira] [Commented] (KAFKA-3905) remove null from subscribed topics in KafkaConsumer#subscribe

[ https://issues.apache.org/jira/browse/KAFKA-3905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15369204#comment-15369204 ] ASF GitHub Bot commented on KAFKA-3905: --- Github user rekhajoshm closed the pull requ

[GitHub] kafka pull request #1561: KAFKA-3905; Handle invalid collection of topics, p...

Github user rekhajoshm closed the pull request at: https://github.com/apache/kafka/pull/1561 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (KAFKA-3911) Enforce KTable materialization

[ https://issues.apache.org/jira/browse/KAFKA-3911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15369091#comment-15369091 ] Eno Thereska commented on KAFKA-3911: - This JIRA needs to be done strictly after KAFKA

[GitHub] kafka pull request #1600: KAFKA-3942: Change IntegrationTestUtils.purgeLocal...

GitHub user dguy opened a pull request: https://github.com/apache/kafka/pull/1600 KAFKA-3942: Change IntegrationTestUtils.purgeLocalStreamsState to use java.io.tmpdir It was previously only deleting files/folders where the path started with /tmp. Changed it to delete from the value

[jira] [Commented] (KAFKA-3942) Change IntegrationTestUtils.purgeLocalStreamsState to use java.io.tmpdir

[ https://issues.apache.org/jira/browse/KAFKA-3942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15369019#comment-15369019 ] ASF GitHub Bot commented on KAFKA-3942: --- GitHub user dguy opened a pull request:

[jira] [Created] (KAFKA-3942) Change IntegrationTestUtils.purgeLocalStreamsState to use java.io.tmpdir

Damian Guy created KAFKA-3942: - Summary: Change IntegrationTestUtils.purgeLocalStreamsState to use java.io.tmpdir Key: KAFKA-3942 URL: https://issues.apache.org/jira/browse/KAFKA-3942 Project: Kafka