[GitHub] kafka pull request #1557: Improved warning to be clear on first read.

2016-06-26 Thread LuboVarga
GitHub user LuboVarga opened a pull request: https://github.com/apache/kafka/pull/1557 Improved warning to be clear on first read. I hope it will make searching for reason it is actually shown a bit cleaner. Changed just text. Also fixed typo (server parameter is not calle

[jira] [Commented] (KAFKA-3410) Unclean leader election and "Halting because log truncation is not allowed"

2016-06-26 Thread wanny (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350417#comment-15350417 ] wanny commented on KAFKA-3410: -- my kafka 0.9.0.1 run into something very similar for the __co

[jira] [Comment Edited] (KAFKA-3902) Optimize KTable.filter() to reduce unnecessary traffic

2016-06-26 Thread Phil Derome (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350149#comment-15350149 ] Phil Derome edited comment on KAFKA-3902 at 6/26/16 10:24 PM: --

[jira] [Commented] (KAFKA-3834) Consumer should not block in poll on coordinator discovery

2016-06-26 Thread Peter Davis (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350268#comment-15350268 ] Peter Davis commented on KAFKA-3834: I believe we have seen this issue IRL when the ne

Re: KTable.filter usage, memory consumption and materialized view semantics

2016-06-26 Thread Philippe Derome
Guozhang, would you say it's advisable to initialize KTableFilter.sendOldValues to true instead of false? That's what I see that can trigger your described case 3 to potentially desirable effect, but I didn't include it into pull request. If left to default value of false, I don't know what mechan

[jira] [Comment Edited] (KAFKA-3902) Optimize KTable.filter() to reduce unnecessary traffic

2016-06-26 Thread Phil Derome (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350149#comment-15350149 ] Phil Derome edited comment on KAFKA-3902 at 6/26/16 3:55 PM: -

Re: [DISCUSS] KIP-65 Expose timestamps to Connect

2016-06-26 Thread Shikhar Bhushan
I updated the KIP and PR with this change On Fri, Jun 24, 2016 at 4:58 PM Ismael Juma wrote: > Yes, I agree that it would be better to be consistent. I suggest `Long` and > `null` everywhere if feasible as it's less opaque than the magic -1L value. > The KIP page should be updated with what you

[jira] [Commented] (KAFKA-3902) Optimize KTable.filter() to reduce unnecessary traffic

2016-06-26 Thread Phil Derome (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350149#comment-15350149 ] Phil Derome commented on KAFKA-3902: The problem above is not quite a real problem bec

[jira] [Commented] (KAFKA-3902) Optimize KTable.filter() to reduce unnecessary traffic

2016-06-26 Thread Phil Derome (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350131#comment-15350131 ] Phil Derome commented on KAFKA-3902: I am currently having a problem when porting Conf

[jira] [Commented] (KAFKA-3825) Allow users to specify different types of state stores in Streams DSL

2016-06-26 Thread Jeyhun Karimov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350110#comment-15350110 ] Jeyhun Karimov commented on KAFKA-3825: --- [~guozhang] I am starting on this issue and

[jira] [Issue Comment Deleted] (KAFKA-3902) Optimize KTable.filter() to reduce unnecessary traffic

2016-06-26 Thread Phil Derome (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phil Derome updated KAFKA-3902: --- Comment: was deleted (was: one liner fix, but am unfamiliar with github and submitting proper pull re

[GitHub] kafka pull request #1556: KAFKA-3902

2016-06-26 Thread phderome
GitHub user phderome opened a pull request: https://github.com/apache/kafka/pull/1556 KAFKA-3902 The contribution is my original work and that I license the work to the project under the project's open source license. Contributors: Guozhang Wang, Phil Derome @guozhangwa

[jira] [Commented] (KAFKA-3902) Optimize KTable.filter() to reduce unnecessary traffic

2016-06-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350099#comment-15350099 ] ASF GitHub Bot commented on KAFKA-3902: --- GitHub user phderome opened a pull request:

[GitHub] kafka pull request #1555: MINOR: Fix ambiguous log message in RecordCollecto...

2016-06-26 Thread kawamuray
GitHub user kawamuray opened a pull request: https://github.com/apache/kafka/pull/1555 MINOR: Fix ambiguous log message in RecordCollector When producing fails in Kafka Streams, it gives an error like below: ``` Error sending record: null ``` by this line:

[jira] [Commented] (KAFKA-3904) File descriptor leaking (Too many open files) for long running stream process

2016-06-26 Thread Henry Cai (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350018#comment-15350018 ] Henry Cai commented on KAFKA-3904: -- I have the fix also: -FileChannel channel =