[jira] [Commented] (KAFKA-187) Add Snappy Compression as a Codec

2011-11-06 Thread Joe Stein (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13144950#comment-13144950 ] Joe Stein commented on KAFKA-187: - {quote} 1. There is quite a lot of overlap in the code

[jira] [Commented] (KAFKA-187) Add Snappy Compression as a Codec

2011-11-06 Thread Joe Stein (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13145077#comment-13145077 ] Joe Stein commented on KAFKA-187: - 1) sounds good to me, I opened another JIRA but will com

[jira] [Commented] (KAFKA-187) Add Snappy Compression as a Codec and refactor CompressionUtil and option on startup to select what the default codec

2011-11-07 Thread Joe Stein (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13145770#comment-13145770 ] Joe Stein commented on KAFKA-187: - Yes, this patch allows for that. Here is how to verify.

[jira] [Commented] (KAFKA-193) use by name parameter helper for logging and trait to include lazy logging and refactor code to use the new LogHelper

2011-11-11 Thread Joe Stein (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13148985#comment-13148985 ] Joe Stein commented on KAFKA-193: - Well, error and fatal have overloaded for throwable sinc

[jira] [Commented] (KAFKA-240) implement new producer and consumer request format

2012-01-10 Thread Joe Stein (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13183581#comment-13183581 ] Joe Stein commented on KAFKA-240: - so I started looking at parts of the code and the docume

[jira] [Commented] (KAFKA-203) Improve Kafka internal metrics

2012-01-10 Thread Joe Stein (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13183760#comment-13183760 ] Joe Stein commented on KAFKA-203: - I have implemented Coda Hale's Metric package and have i

[jira] [Commented] (KAFKA-240) implement new producer and consumer request format

2012-01-16 Thread Joe Stein (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13186982#comment-13186982 ] Joe Stein commented on KAFKA-240: - I have been looking and going through the producer side

[jira] [Commented] (KAFKA-240) implement new producer and consumer request format

2012-01-18 Thread Joe Stein (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13188479#comment-13188479 ] Joe Stein commented on KAFKA-240: - So, one possibility I am looking at for the data [] is t

[jira] [Commented] (KAFKA-240) implement new producer and consumer request format

2012-01-18 Thread Joe Stein (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13188617#comment-13188617 ] Joe Stein commented on KAFKA-240: - << we just need a way to encode array structures right,

[jira] [Commented] (KAFKA-240) implement new producer and consumer request format

2012-01-18 Thread Joe Stein (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13188764#comment-13188764 ] Joe Stein commented on KAFKA-240: - yup, that is much simpler :) here is my first crack on

[jira] [Commented] (KAFKA-193) use by name parameter helper for logging and trait to include lazy logging and refactor code to use the new LogHelper

2012-01-18 Thread Joe Stein (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1310#comment-1310 ] Joe Stein commented on KAFKA-193: - The issue looks like it is with Scala 2.8.0 I build and

[jira] [Commented] (KAFKA-240) implement new producer and consumer request format

2012-01-21 Thread Joe Stein (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13190598#comment-13190598 ] Joe Stein commented on KAFKA-240: - more progress on the producer side https://gist.github.c

[jira] [Commented] (KAFKA-259) Exception in thread "main" java.lang.NoClassDefFoundError: kafka/Kafka Caused by: java.lang.ClassNotFoundException: kafka.Kafka

2012-01-31 Thread Joe Stein (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13196942#comment-13196942 ] Joe Stein commented on KAFKA-259: - cd kafka ./sbt update ./sbt package this will make the

[jira] [Commented] (KAFKA-260) Add audit trail to kafka

2012-02-01 Thread Joe Stein (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13197775#comment-13197775 ] Joe Stein commented on KAFKA-260: - is "application" synonymous with the new wired format "c

[jira] [Commented] (KAFKA-240) implement new producer and consumer request format

2012-02-03 Thread Joe Stein (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13199975#comment-13199975 ] Joe Stein commented on KAFKA-240: - I am finishing up the changes for SyncProducer and shoul

[jira] [Commented] (KAFKA-240) implement new producer and consumer request format

2012-02-03 Thread Joe Stein (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13200333#comment-13200333 ] Joe Stein commented on KAFKA-240: - here is the latest on the ProducerRequest https://gist.

[jira] [Commented] (KAFKA-240) implement new producer and consumer request format

2012-02-05 Thread Joe Stein (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13200907#comment-13200907 ] Joe Stein commented on KAFKA-240: - here are my changes https://gist.github.com/1748005 I do

[jira] [Commented] (KAFKA-240) implement new producer and consumer request format

2012-02-08 Thread Joe Stein (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13204188#comment-13204188 ] Joe Stein commented on KAFKA-240: - Yes, sounds good. I will apply his patch and refactor m

[jira] [Commented] (KAFKA-240) implement new producer and consumer request format

2012-02-10 Thread Joe Stein (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13205566#comment-13205566 ] Joe Stein commented on KAFKA-240: - Hey guys, so I started integrate my changes over Prashan

[jira] [Commented] (KAFKA-240) implement new producer and consumer request format

2012-02-15 Thread Joe Stein (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13208841#comment-13208841 ] Joe Stein commented on KAFKA-240: - cool, so I need to rebase, update my changes for the few

[jira] [Commented] (KAFKA-240) implement new producer and consumer request format

2012-02-26 Thread Joe Stein (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13217073#comment-13217073 ] Joe Stein commented on KAFKA-240: - for #2 the reason I left send(topic: String, messages:

[jira] [Commented] (KAFKA-287) Running a consumer client using scala 2.8 fails

2012-02-28 Thread Joe Stein (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13218574#comment-13218574 ] Joe Stein commented on KAFKA-287: - I run Kafka in production using Scala 2.9.1 changing bui

[jira] [Commented] (KAFKA-134) Upgrade Kafka to sbt 0.10.1

2012-02-28 Thread Joe Stein (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13218575#comment-13218575 ] Joe Stein commented on KAFKA-134: - we should look at going up to 11.2 now once we catch up

[jira] [Commented] (KAFKA-284) C++ client does not compile

2012-02-28 Thread Joe Stein (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13218595#comment-13218595 ] Joe Stein commented on KAFKA-284: - Niek do you want to upload a patch for this?

[jira] [Commented] (KAFKA-284) C++ client does not compile

2012-02-28 Thread Joe Stein (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13218603#comment-13218603 ] Joe Stein commented on KAFKA-284: - I noticed another thing also autoconf.sh does not have

[jira] [Commented] (KAFKA-284) C++ client does not compile

2012-02-29 Thread Joe Stein (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13219753#comment-13219753 ] Joe Stein commented on KAFKA-284: - committed > C++ client does not compile

[jira] [Commented] (KAFKA-240) implement new producer and consumer request format

2012-03-02 Thread Joe Stein (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13221162#comment-13221162 ] Joe Stein commented on KAFKA-240: - ok, sounds good. I will commit the changes with these l

[jira] [Commented] (KAFKA-240) implement new producer and consumer request format

2012-03-02 Thread Joe Stein (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13221290#comment-13221290 ] Joe Stein commented on KAFKA-240: - Hi Jun, on #9 def readFrom(buffer: ByteBuffer): Prod

[jira] [Commented] (KAFKA-240) implement new producer and consumer request format

2012-03-02 Thread Joe Stein (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13221353#comment-13221353 ] Joe Stein commented on KAFKA-240: - It is written to the buffer though it is not passed in w

[jira] [Commented] (KAFKA-240) implement new producer and consumer request format

2012-03-02 Thread Joe Stein (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13221495#comment-13221495 ] Joe Stein commented on KAFKA-240: - Thanks Jun, I get the issue now. Right, so after I read

[jira] [Commented] (KAFKA-240) implement new producer and consumer request format

2012-03-02 Thread Joe Stein (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13221523#comment-13221523 ] Joe Stein commented on KAFKA-240: - 9) done 10) done change member vars to camel case for c

[jira] [Commented] (KAFKA-266) Kafka web console design

2012-03-14 Thread Joe Stein (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13229285#comment-13229285 ] Joe Stein commented on KAFKA-266: - JMX, HTTP are both fine but also hooking into Graphite,