[jira] [Commented] (KAFKA-4830) Augment KStream.print() to allow users pass in extra parameters in the printed string

[ https://issues.apache.org/jira/browse/KAFKA-4830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16017189#comment-16017189 ] james chien commented on KAFKA-4830: [~mjsax] Okay, I will study about how to write it

[jira] [Commented] (KAFKA-4830) Augment KStream.print() to allow users pass in extra parameters in the printed string

[ https://issues.apache.org/jira/browse/KAFKA-4830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16015486#comment-16015486 ] james chien commented on KAFKA-4830: [~mjsax] I just make a new PR. https://github.com

[jira] [Comment Edited] (KAFKA-4830) Augment KStream.print() to allow users pass in extra parameters in the printed string

[ https://issues.apache.org/jira/browse/KAFKA-4830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16015110#comment-16015110 ] james chien edited comment on KAFKA-4830 at 5/18/17 2:41 AM: -

[jira] [Comment Edited] (KAFKA-4830) Augment KStream.print() to allow users pass in extra parameters in the printed string

[ https://issues.apache.org/jira/browse/KAFKA-4830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16015110#comment-16015110 ] james chien edited comment on KAFKA-4830 at 5/18/17 2:41 AM: -

[jira] [Commented] (KAFKA-4830) Augment KStream.print() to allow users pass in extra parameters in the printed string

[ https://issues.apache.org/jira/browse/KAFKA-4830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16015110#comment-16015110 ] james chien commented on KAFKA-4830: I think if we do that then we will introduce a ne

[jira] [Comment Edited] (KAFKA-4830) Augment KStream.print() to allow users pass in extra parameters in the printed string

[ https://issues.apache.org/jira/browse/KAFKA-4830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16015110#comment-16015110 ] james chien edited comment on KAFKA-4830 at 5/18/17 2:40 AM: -

[jira] [Commented] (KAFKA-4830) Augment KStream.print() to allow users pass in extra parameters in the printed string

[ https://issues.apache.org/jira/browse/KAFKA-4830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16015043#comment-16015043 ] james chien commented on KAFKA-4830: great, I will work on this :) > Augment KStream.

[jira] [Assigned] (KAFKA-4830) Augment KStream.print() to allow users pass in extra parameters in the printed string

[ https://issues.apache.org/jira/browse/KAFKA-4830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] james chien reassigned KAFKA-4830: -- Assignee: james chien > Augment KStream.print() to allow users pass in extra parameters in the

[jira] [Commented] (KAFKA-4772) Exploit #peek to implement #print() and other methods

[ https://issues.apache.org/jira/browse/KAFKA-4772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15992704#comment-15992704 ] james chien commented on KAFKA-4772: my new PR is here https://github.com/apache/kafka

[jira] [Commented] (KAFKA-4772) Exploit #peek to implement #print() and other methods

[ https://issues.apache.org/jira/browse/KAFKA-4772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15992298#comment-15992298 ] james chien commented on KAFKA-4772: okay, times to resolve this :) :) > Exploit #pee

[jira] [Comment Edited] (KAFKA-4772) Exploit #peek to implement #print() and other methods

[ https://issues.apache.org/jira/browse/KAFKA-4772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991968#comment-15991968 ] james chien edited comment on KAFKA-4772 at 5/2/17 1:54 AM: Gr

[jira] [Commented] (KAFKA-4772) Exploit #peek to implement #print() and other methods

[ https://issues.apache.org/jira/browse/KAFKA-4772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991968#comment-15991968 ] james chien commented on KAFKA-4772: Great !! what should I do now? (keep going this

[jira] [Comment Edited] (KAFKA-4772) Exploit #peek to implement #print() and other methods

[ https://issues.apache.org/jira/browse/KAFKA-4772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15989761#comment-15989761 ] james chien edited comment on KAFKA-4772 at 4/29/17 4:53 AM: -

[jira] [Commented] (KAFKA-4772) Exploit #peek to implement #print() and other methods

[ https://issues.apache.org/jira/browse/KAFKA-4772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15989761#comment-15989761 ] james chien commented on KAFKA-4772: okay, I will start to resolve this issue. > Expl

[jira] [Comment Edited] (KAFKA-4772) Exploit #peek to implement #print() and other methods

[ https://issues.apache.org/jira/browse/KAFKA-4772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15989732#comment-15989732 ] james chien edited comment on KAFKA-4772 at 4/29/17 3:36 AM: -

[jira] [Comment Edited] (KAFKA-4772) Exploit #peek to implement #print() and other methods

[ https://issues.apache.org/jira/browse/KAFKA-4772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15989732#comment-15989732 ] james chien edited comment on KAFKA-4772 at 4/29/17 3:35 AM: -

[jira] [Comment Edited] (KAFKA-4772) Exploit #peek to implement #print() and other methods

[ https://issues.apache.org/jira/browse/KAFKA-4772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15989732#comment-15989732 ] james chien edited comment on KAFKA-4772 at 4/29/17 3:34 AM: -

[jira] [Comment Edited] (KAFKA-4772) Exploit #peek to implement #print() and other methods

[ https://issues.apache.org/jira/browse/KAFKA-4772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15989732#comment-15989732 ] james chien edited comment on KAFKA-4772 at 4/29/17 3:35 AM: -

[jira] [Comment Edited] (KAFKA-4772) Exploit #peek to implement #print() and other methods

[ https://issues.apache.org/jira/browse/KAFKA-4772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15989732#comment-15989732 ] james chien edited comment on KAFKA-4772 at 4/29/17 3:34 AM: -

[jira] [Comment Edited] (KAFKA-4772) Exploit #peek to implement #print() and other methods

[ https://issues.apache.org/jira/browse/KAFKA-4772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15989732#comment-15989732 ] james chien edited comment on KAFKA-4772 at 4/29/17 3:33 AM: -

[jira] [Commented] (KAFKA-4772) Exploit #peek to implement #print() and other methods

[ https://issues.apache.org/jira/browse/KAFKA-4772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15989732#comment-15989732 ] james chien commented on KAFKA-4772: I think I got it, this JIRA is about replacing {`

[jira] [Comment Edited] (KAFKA-4772) Exploit #peek to implement #print() and other methods

[ https://issues.apache.org/jira/browse/KAFKA-4772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15989732#comment-15989732 ] james chien edited comment on KAFKA-4772 at 4/29/17 3:32 AM: -

[jira] [Commented] (KAFKA-4772) Exploit #peek to implement #print() and other methods

[ https://issues.apache.org/jira/browse/KAFKA-4772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15989132#comment-15989132 ] james chien commented on KAFKA-4772: As you said, it seems like no issue exists anymor

[jira] [Comment Edited] (KAFKA-4772) Exploit #peek to implement #print() and other methods

[ https://issues.apache.org/jira/browse/KAFKA-4772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988365#comment-15988365 ] james chien edited comment on KAFKA-4772 at 4/28/17 9:19 AM: -

[jira] [Comment Edited] (KAFKA-4772) Exploit #peek to implement #print() and other methods

[ https://issues.apache.org/jira/browse/KAFKA-4772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988365#comment-15988365 ] james chien edited comment on KAFKA-4772 at 4/28/17 7:37 AM: -

[jira] [Comment Edited] (KAFKA-4772) Exploit #peek to implement #print() and other methods

[ https://issues.apache.org/jira/browse/KAFKA-4772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988365#comment-15988365 ] james chien edited comment on KAFKA-4772 at 4/28/17 7:37 AM: -

[jira] [Commented] (KAFKA-4772) Exploit #peek to implement #print() and other methods

[ https://issues.apache.org/jira/browse/KAFKA-4772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988365#comment-15988365 ] james chien commented on KAFKA-4772: I think I know it. This idea is good, and we want

[jira] [Comment Edited] (KAFKA-4772) Exploit #peek to implement #print() and other methods

[ https://issues.apache.org/jira/browse/KAFKA-4772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988025#comment-15988025 ] james chien edited comment on KAFKA-4772 at 4/28/17 1:51 AM: -

[jira] [Comment Edited] (KAFKA-4772) Exploit #peek to implement #print() and other methods

[ https://issues.apache.org/jira/browse/KAFKA-4772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988025#comment-15988025 ] james chien edited comment on KAFKA-4772 at 4/28/17 1:49 AM: -

[jira] [Comment Edited] (KAFKA-4772) Exploit #peek to implement #print() and other methods

[ https://issues.apache.org/jira/browse/KAFKA-4772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988025#comment-15988025 ] james chien edited comment on KAFKA-4772 at 4/28/17 1:47 AM: -

[jira] [Commented] (KAFKA-4830) Augment KStream.print() to allow users pass in extra parameters in the printed string

[ https://issues.apache.org/jira/browse/KAFKA-4830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988028#comment-15988028 ] james chien commented on KAFKA-4830: yes, I want to work on that ! > Augment KStream.

[jira] [Assigned] (KAFKA-4772) Exploit #peek to implement #print() and other methods

[ https://issues.apache.org/jira/browse/KAFKA-4772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] james chien reassigned KAFKA-4772: -- Assignee: james chien > Exploit #peek to implement #print() and other methods > ---

[jira] [Commented] (KAFKA-4772) Exploit #peek to implement #print() and other methods

[ https://issues.apache.org/jira/browse/KAFKA-4772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988025#comment-15988025 ] james chien commented on KAFKA-4772: I want to clarify the problem, as I know is want

[jira] [Comment Edited] (KAFKA-4830) Augment KStream.print() to allow users pass in extra parameters in the printed string

[ https://issues.apache.org/jira/browse/KAFKA-4830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15986208#comment-15986208 ] james chien edited comment on KAFKA-4830 at 4/27/17 8:51 AM: -

[jira] [Commented] (KAFKA-4830) Augment KStream.print() to allow users pass in extra parameters in the printed string

[ https://issues.apache.org/jira/browse/KAFKA-4830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15986208#comment-15986208 ] james chien commented on KAFKA-4830: the issue still exists? > Augment KStream.print(

[jira] [Updated] (KAFKA-5133) Changing "connection refused" message from logging level "debug" into "warn"

[ https://issues.apache.org/jira/browse/KAFKA-5133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] james chien updated KAFKA-5133: --- Description: If broker is down, we supply logging message to let user know `java.net.ConnectException

[jira] [Updated] (KAFKA-5133) Changing "connection refused" message from logging level "debug" into "warn"

[ https://issues.apache.org/jira/browse/KAFKA-5133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] james chien updated KAFKA-5133: --- Description: If broker is down, we supply logging message to let user know `java.net.ConnectException

[jira] [Updated] (KAFKA-5133) Changing "connection refused" message from logging level "debug" into "warn"

[ https://issues.apache.org/jira/browse/KAFKA-5133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] james chien updated KAFKA-5133: --- Description: If broker is down, we supply logging message to let user know `java.net.ConnectException

[jira] [Updated] (KAFKA-5133) Changing "connection refused" message from logging level "debug" into "warn"

[ https://issues.apache.org/jira/browse/KAFKA-5133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] james chien updated KAFKA-5133: --- External issue URL: https://github.com/apache/kafka/pull/2850 > Changing "connection refused" message

[jira] [Updated] (KAFKA-5133) Changing "connection refused" message from logging level "debug" into "warn"

[ https://issues.apache.org/jira/browse/KAFKA-5133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] james chien updated KAFKA-5133: --- External issue URL: https://github.com/apache/kafka/pull/2924 (was: https://github.com/apache/kafka/p

[jira] [Updated] (KAFKA-5133) Changing "connection refused" message from logging level "debug" into "warn"

[ https://issues.apache.org/jira/browse/KAFKA-5133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] james chien updated KAFKA-5133: --- Description: If broker is down, we supply logging message to let user know `java.net.ConnectException

[jira] [Created] (KAFKA-5133) Changing "connection refused" message from logging level "debug" into "warn"

james chien created KAFKA-5133: -- Summary: Changing "connection refused" message from logging level "debug" into "warn" Key: KAFKA-5133 URL: https://issues.apache.org/jira/browse/KAFKA-5133 Project: Kafka

[jira] [Comment Edited] (KAFKA-5065) AbstractCoordinator.ensureCoordinatorReady() stuck in loop if absent any bootstrap servers

[ https://issues.apache.org/jira/browse/KAFKA-5065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980629#comment-15980629 ] james chien edited comment on KAFKA-5065 at 4/25/17 2:40 AM: -

[jira] [Comment Edited] (KAFKA-5065) AbstractCoordinator.ensureCoordinatorReady() stuck in loop if absent any bootstrap servers

[ https://issues.apache.org/jira/browse/KAFKA-5065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15982296#comment-15982296 ] james chien edited comment on KAFKA-5065 at 4/25/17 2:39 AM: -

[jira] [Assigned] (KAFKA-5065) AbstractCoordinator.ensureCoordinatorReady() stuck in loop if absent any bootstrap servers

[ https://issues.apache.org/jira/browse/KAFKA-5065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] james chien reassigned KAFKA-5065: -- Assignee: james chien we should not replace Long.MAX_VALUE for custom setting, but should make

[jira] [Comment Edited] (KAFKA-5065) AbstractCoordinator.ensureCoordinatorReady() stuck in loop if absent any bootstrap servers

[ https://issues.apache.org/jira/browse/KAFKA-5065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980629#comment-15980629 ] james chien edited comment on KAFKA-5065 at 4/24/17 2:28 AM: -

[jira] [Commented] (KAFKA-5065) AbstractCoordinator.ensureCoordinatorReady() stuck in loop if absent any bootstrap servers

[ https://issues.apache.org/jira/browse/KAFKA-5065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980629#comment-15980629 ] james chien commented on KAFKA-5065: Hi, I notice that why to use MAX.LONG is as the c

[jira] [Comment Edited] (KAFKA-5065) AbstractCoordinator.ensureCoordinatorReady() stuck in loop if absent any bootstrap servers

[ https://issues.apache.org/jira/browse/KAFKA-5065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980629#comment-15980629 ] james chien edited comment on KAFKA-5065 at 4/24/17 2:00 AM: -

[jira] [Commented] (KAFKA-5065) AbstractCoordinator.ensureCoordinatorReady() stuck in loop if absent any bootstrap servers

[ https://issues.apache.org/jira/browse/KAFKA-5065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15978228#comment-15978228 ] james chien commented on KAFKA-5065: I am a newbie, I want to take this issue. > Abst