[jira] [Commented] (KAFKA-4908) consumer.properties logging warnings

2017-03-19 Thread huxi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15932099#comment-15932099 ] huxi commented on KAFKA-4908: - `zookeeper.connection.timeout.ms` and `zookeeper.connect` are

[jira] [Updated] (KAFKA-4914) Partition re-assignment tool should check types before persisting state in ZooKeeper

2017-03-19 Thread Nick Travers (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nick Travers updated KAFKA-4914: Status: Patch Available (was: Open) > Partition re-assignment tool should check types before persis

[jira] [Commented] (KAFKA-4914) Partition re-assignment tool should check types before persisting state in ZooKeeper

2017-03-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15931974#comment-15931974 ] ASF GitHub Bot commented on KAFKA-4914: --- GitHub user nicktrav opened a pull request:

[GitHub] kafka pull request #2708: KAFKA-4914: Partition re-assignment tool should ch...

2017-03-19 Thread nicktrav
GitHub user nicktrav opened a pull request: https://github.com/apache/kafka/pull/2708 KAFKA-4914: Partition re-assignment tool should check types before pe… …rsisting state in ZooKeeper Check the structure of the partition re-assignment JSON string on both --verify a

[jira] [Updated] (KAFKA-4919) Streams job fails with InvalidStateStoreException: Store is currently closed

2017-03-19 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Elias Levy updated KAFKA-4919: -- Summary: Streams job fails with InvalidStateStoreException: Store is currently closed (was: Streams job

[jira] [Created] (KAFKA-4919) Streams job fails with StreamsExceptio

2017-03-19 Thread Elias Levy (JIRA)
Elias Levy created KAFKA-4919: - Summary: Streams job fails with StreamsExceptio Key: KAFKA-4919 URL: https://issues.apache.org/jira/browse/KAFKA-4919 Project: Kafka Issue Type: Bug Comp

[GitHub] kafka pull request #2707: MINOR: exchanged addAll/putAll with parametrized c...

2017-03-19 Thread wlsc
GitHub user wlsc opened a pull request: https://github.com/apache/kafka/pull/2707 MINOR: exchanged addAll/putAll with parametrized constructor Basic static analysis was done here. I've exchanged all addAll/putAll methods that were stand right after creation of each particul

[GitHub] kafka pull request #2706: MINOR: fixed memory pollution by removing unnecess...

2017-03-19 Thread wlsc
GitHub user wlsc opened a pull request: https://github.com/apache/kafka/pull/2706 MINOR: fixed memory pollution by removing unnecessary creation of HashSet MINOR: fixed memory pollution by removing unnecessary creation of HashSet (assignment and subscription functions), changed modi

[GitHub] kafka pull request #2697: MINOR: fixed memory pollution in KafkaConsumer

2017-03-19 Thread wlsc
Github user wlsc closed the pull request at: https://github.com/apache/kafka/pull/2697 --- 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 enable