[jira] [Commented] (KAFKA-736) Add an option to the 0.8 producer to mimic 0.7 producer behavior

[ https://issues.apache.org/jira/browse/KAFKA-736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13569320#comment-13569320 ] ben fleis commented on KAFKA-736: - This is more-or-less what my node command line tool does

[jira] [Commented] (KAFKA-736) Add an option to the 0.8 producer to mimic 0.7 producer behavior

[ https://issues.apache.org/jira/browse/KAFKA-736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13569294#comment-13569294 ] ben fleis commented on KAFKA-736: - Went back and tested the 'draft' patch, and this failed

[jira] [Commented] (KAFKA-736) Add an option to the 0.8 producer to mimic 0.7 producer behavior

[ https://issues.apache.org/jira/browse/KAFKA-736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13568192#comment-13568192 ] ben fleis commented on KAFKA-736: - I tried the v2 patch linked above this morning against v

[jira] [Created] (KAFKA-706) broker appears to be encoding ProduceResponse, but never sending it

ben fleis created KAFKA-706: --- Summary: broker appears to be encoding ProduceResponse, but never sending it Key: KAFKA-706 URL: https://issues.apache.org/jira/browse/KAFKA-706 Project: Kafka Issue

[jira] [Created] (KAFKA-704) ConsumerFetcherThread can create illegal clientId

ben fleis created KAFKA-704: --- Summary: ConsumerFetcherThread can create illegal clientId Key: KAFKA-704 URL: https://issues.apache.org/jira/browse/KAFKA-704 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-692) ConsoleConsumer outputs diagnostic message to stdout instead of stderr

[ https://issues.apache.org/jira/browse/KAFKA-692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13552214#comment-13552214 ] ben fleis commented on KAFKA-692: - Agreed - I just patched it so it didn't get in my way on

[jira] [Updated] (KAFKA-692) ConsoleConsumer outputs diagnostic message to stdout instead of stderr

[ https://issues.apache.org/jira/browse/KAFKA-692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ben fleis updated KAFKA-692: Description: At the end of its handling loop, ConsoleConsumer prints "Consumed %d messages" to standard out

[jira] [Issue Comment Deleted] (KAFKA-692) ConsoleConsumer outputs diagnostic message to stdout instead of stderr

[ https://issues.apache.org/jira/browse/KAFKA-692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ben fleis updated KAFKA-692: Comment: was deleted (was: from stdout -> stderr) > ConsoleConsumer outputs diagnostic message to stdou

[jira] [Updated] (KAFKA-692) ConsoleConsumer outputs diagnostic message to stdout instead of stderr

[ https://issues.apache.org/jira/browse/KAFKA-692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ben fleis updated KAFKA-692: Attachment: kafka_692_v1.diff stdout -> stderr > ConsoleConsumer outputs diagnostic message

[jira] [Updated] (KAFKA-692) ConsoleConsumer outputs diagnostic message to stdout instead of stderr

[ https://issues.apache.org/jira/browse/KAFKA-692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ben fleis updated KAFKA-692: Status: Patch Available (was: Open) from stdout -> stderr > ConsoleConsumer outputs diagno

[jira] [Created] (KAFKA-692) ConsoleConsumer outputs diagnostic message to stdout instead of stderr

ben fleis created KAFKA-692: --- Summary: ConsoleConsumer outputs diagnostic message to stdout instead of stderr Key: KAFKA-692 URL: https://issues.apache.org/jira/browse/KAFKA-692 Project: Kafka Iss

[jira] [Commented] (KAFKA-133) Publish kafka jar to a public maven repository

[ https://issues.apache.org/jira/browse/KAFKA-133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13549515#comment-13549515 ] ben fleis commented on KAFKA-133: - I'm new to maven, so this may be a dumb question: would

[jira] [Commented] (KAFKA-689) Can't append to a topic/partition that does not already exist

[ https://issues.apache.org/jira/browse/KAFKA-689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13549500#comment-13549500 ] ben fleis commented on KAFKA-689: - Although it's not precisely the same, perhaps thinking a