[jira] [Resolved] (KAFKA-1551) Configuration example errors

2014-07-20 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-1551. -- Resolution: Fixed Fixed. Configuration example errors

[jira] [Updated] (KAFKA-1552) Quickstart refers to wrong port in pastable commands

2014-07-20 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-1552: - Assignee: Olle Jonsson Quickstart refers to wrong port in pastable commands

[jira] [Updated] (KAFKA-1552) Quickstart refers to wrong port in pastable commands

2014-07-20 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-1552: - Resolution: Fixed Status: Resolved (was: Patch Available) Fixed, thanks! Quickstart refers to

[jira] [Updated] (KAFKA-1551) Configuration example errors

2014-07-20 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-1551: - Assignee: Alexey Ozeritskiy Configuration example errors

[jira] [Commented] (KAFKA-1414) Speedup broker startup after hard reset

2014-07-20 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14068021#comment-14068021 ] Jay Kreps commented on KAFKA-1414: -- We should check that having multiple threads

[jira] [Commented] (KAFKA-1414) Speedup broker startup after hard reset

2014-07-20 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14068173#comment-14068173 ] Jay Kreps commented on KAFKA-1414: -- I did a test of single-threaded recovery on my laptop

[jira] [Commented] (KAFKA-1414) Speedup broker startup after hard reset

2014-07-20 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14068177#comment-14068177 ] Jay Kreps commented on KAFKA-1414: -- [~ataraxer] I agree that just throwing all the logs

[jira] [Commented] (KAFKA-1535) return all live brokers in TopicMetadataResponse

2014-07-18 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14066439#comment-14066439 ] Jay Kreps commented on KAFKA-1535: -- To date we have not really used pull requests. Apache

[jira] [Commented] (KAFKA-1150) Fetch on a replicated topic does not return as soon as possible

2014-07-18 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14066440#comment-14066440 ] Jay Kreps commented on KAFKA-1150: -- Yeah, [~thecoop1984], can you verify that the patch

[jira] [Commented] (KAFKA-1282) Disconnect idle socket connection in Selector

2014-07-18 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14066461#comment-14066461 ] Jay Kreps commented on KAFKA-1282: -- The goal is just to reduce server connection count.

[jira] [Commented] (KAFKA-1476) Get a list of consumer groups

2014-07-18 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14066471#comment-14066471 ] Jay Kreps commented on KAFKA-1476: -- This looks good to me. One thing we should think

[jira] [Commented] (KAFKA-1476) Get a list of consumer groups

2014-07-18 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14066583#comment-14066583 ] Jay Kreps commented on KAFKA-1476: -- Cool, so [~balaji.seshadri] would you be willing to

[jira] [Commented] (KAFKA-1535) return all live brokers in TopicMetadataResponse

2014-07-18 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14067074#comment-14067074 ] Jay Kreps commented on KAFKA-1535: -- [~nmarasoi] Totally up to you. return all live

[jira] [Commented] (KAFKA-1543) Changing replication factor

2014-07-17 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14065616#comment-14065616 ] Jay Kreps commented on KAFKA-1543: -- I wonder if it would make more sense to have the

[jira] [Resolved] (KAFKA-169) Layering violations in Kafka code

2014-07-17 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-169. - Resolution: Won't Fix Layering violations in Kafka code -

[jira] [Commented] (KAFKA-1535) return all live brokers in TopicMetadataResponse

2014-07-17 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14065646#comment-14065646 ] Jay Kreps commented on KAFKA-1535: -- Our current model of nodes is that they are

[jira] [Commented] (KAFKA-1070) Auto-assign node id

2014-07-17 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14065702#comment-14065702 ] Jay Kreps commented on KAFKA-1070: -- Hey [~harsha_ch], that is a great point. I'd like to

[jira] [Commented] (KAFKA-1414) Speedup broker startup after hard reset

2014-07-17 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14065721#comment-14065721 ] Jay Kreps commented on KAFKA-1414: -- Hey [~aozeritsky], any before/after perf numbers for

[jira] [Updated] (KAFKA-1535) return all live brokers in TopicMetadataResponse

2014-07-17 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-1535: - Resolution: Fixed Assignee: Jay Kreps Status: Resolved (was: Patch Available) Patch looks

[jira] [Resolved] (KAFKA-183) Expose offset vector to the consumer

2014-07-17 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-183. - Resolution: Fixed This is being done in the new consumer. Expose offset vector to the consumer

[jira] [Commented] (KAFKA-1546) Automate replica lag tuning

2014-07-17 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14065806#comment-14065806 ] Jay Kreps commented on KAFKA-1546: -- I think this is actually a really important thing to

[jira] [Resolved] (KAFKA-1512) Limit the maximum number of connections per ip address

2014-07-16 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-1512. -- Resolution: Fixed Committed. Limit the maximum number of connections per ip address

[jira] [Commented] (KAFKA-1414) Speedup broker startup after hard reset

2014-07-16 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14063742#comment-14063742 ] Jay Kreps commented on KAFKA-1414: -- Great patch! I second Jun's comments. Is there a

[jira] [Commented] (KAFKA-1535) return all live brokers in TopicMetadataResponse

2014-07-16 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14064186#comment-14064186 ] Jay Kreps commented on KAFKA-1535: -- Hey Nicu, this looks good to me. Did you do any

[jira] [Commented] (KAFKA-1535) return all live brokers in TopicMetadataResponse

2014-07-15 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14062214#comment-14062214 ] Jay Kreps commented on KAFKA-1535: -- Yeah we do all development on trunk and just cut

[jira] [Updated] (KAFKA-1512) Limit the maximum number of connections per ip address

2014-07-14 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-1512: - Attachment: KAFKA-1512_2014-07-14_13:28:15.patch Limit the maximum number of connections per ip address

[jira] [Commented] (KAFKA-1512) Limit the maximum number of connections per ip address

2014-07-14 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14061178#comment-14061178 ] Jay Kreps commented on KAFKA-1512: -- Updated reviewboard

[jira] [Updated] (KAFKA-1258) Delete temporary data directory after unit test finishes

2014-07-12 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-1258: - Resolution: Fixed Status: Resolved (was: Patch Available) Committed. Thanks! Delete temporary

[jira] [Commented] (KAFKA-1330) Implement subscribe(TopicPartition...partitions) in the new consumer

2014-07-12 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14059904#comment-14059904 ] Jay Kreps commented on KAFKA-1330: -- Created reviewboard

[jira] [Updated] (KAFKA-1330) Implement subscribe(TopicPartition...partitions) in the new consumer

2014-07-12 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-1330: - Attachment: KAFKA-1330.patch Implement subscribe(TopicPartition...partitions) in the new consumer

[jira] [Commented] (KAFKA-1330) Implement subscribe(TopicPartition...partitions) in the new consumer

2014-07-12 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14059905#comment-14059905 ] Jay Kreps commented on KAFKA-1330: -- Hey [~nmarasoi], sorry had actually been working on

[jira] [Commented] (KAFKA-1330) Implement subscribe(TopicPartition...partitions) in the new consumer

2014-07-12 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14059906#comment-14059906 ] Jay Kreps commented on KAFKA-1330: -- Guys, I posted a very rough draft that implements

[jira] [Commented] (KAFKA-1026) Dynamically Adjust Batch Size Upon Receiving MessageSizeTooLargeException

2014-07-11 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14059044#comment-14059044 ] Jay Kreps commented on KAFKA-1026: -- I believe this is fixed in the new producer, no? We

[jira] [Resolved] (KAFKA-1026) Dynamically Adjust Batch Size Upon Receiving MessageSizeTooLargeException

2014-07-11 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-1026. -- Resolution: Fixed Fix Version/s: (was: 0.9.0) 0.8.2 Cool, closing with

[jira] [Commented] (KAFKA-1040) ConsumerConfig and ProducerConfig do work in the Constructor

2014-07-11 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14059095#comment-14059095 ] Jay Kreps commented on KAFKA-1040: -- Hey guys, I'm not sure I agree with this principle.

[jira] [Commented] (KAFKA-1040) ConsumerConfig and ProducerConfig do work in the Constructor

2014-07-11 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14059175#comment-14059175 ] Jay Kreps commented on KAFKA-1040: -- Not sure I get the analogy, can we be concrete about

[jira] [Commented] (KAFKA-1535) return all live brokers in TopicMetadataResponse

2014-07-11 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14059200#comment-14059200 ] Jay Kreps commented on KAFKA-1535: -- Cool, go for it. Just attach a patch to this issue

[jira] [Commented] (KAFKA-1515) Wake-up Sender upon blocked on fetching leader metadata

2014-07-11 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14059269#comment-14059269 ] Jay Kreps commented on KAFKA-1515: -- I am getting transient hangs after

[jira] [Commented] (KAFKA-1515) Wake-up Sender upon blocked on fetching leader metadata

2014-07-11 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14059286#comment-14059286 ] Jay Kreps commented on KAFKA-1515: -- Committed with a very minor change: I renamed the

[jira] [Commented] (KAFKA-1535) return all live brokers in TopicMetadataResponse

2014-07-11 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14059287#comment-14059287 ] Jay Kreps commented on KAFKA-1535: -- Yes I think that is correct. The current behavior is

[jira] [Commented] (KAFKA-1537) add request.required.acks=-2 to require acks from all replicas

2014-07-11 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14059451#comment-14059451 ] Jay Kreps commented on KAFKA-1537: -- Wouldn't it be somewhat odd that you actually want to

[jira] [Commented] (KAFKA-1325) Fix inconsistent per topic log configs

2014-07-10 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14057521#comment-14057521 ] Jay Kreps commented on KAFKA-1325: -- Regardless of which path we go let's think about

[jira] [Resolved] (KAFKA-1515) Wake-up Sender upon blocked on fetching leader metadata

2014-07-09 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-1515. -- Resolution: Fixed Wake-up Sender upon blocked on fetching leader metadata

[jira] [Commented] (KAFKA-1532) Move CRC32 to AFTER the payload

2014-07-09 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14056441#comment-14056441 ] Jay Kreps commented on KAFKA-1532: -- This is a good idea, but unfortunately would break

[jira] [Commented] (KAFKA-1532) Move CRC32 to AFTER the payload

2014-07-09 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14056444#comment-14056444 ] Jay Kreps commented on KAFKA-1532: -- Also since Kafka itself fully materializes messages

[jira] [Commented] (KAFKA-1532) Move CRC32 to AFTER the payload

2014-07-09 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14056802#comment-14056802 ] Jay Kreps commented on KAFKA-1532: -- It's not unavoidable, but it is pretty hard. To make

[jira] [Commented] (KAFKA-1532) Move CRC32 to AFTER the payload

2014-07-09 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14056806#comment-14056806 ] Jay Kreps commented on KAFKA-1532: -- Your approach where you buffer the message with a

[jira] [Commented] (KAFKA-1532) Move CRC32 to AFTER the payload

2014-07-09 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14056833#comment-14056833 ] Jay Kreps commented on KAFKA-1532: -- Yeah agreed. I think that is doable. Move CRC32 to

[jira] [Commented] (KAFKA-1512) Limit the maximum number of connections per ip address

2014-07-03 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14051899#comment-14051899 ] Jay Kreps commented on KAFKA-1512: -- A proposal from the LI ops team is to also add an

[jira] [Comment Edited] (KAFKA-1512) Limit the maximum number of connections per ip address

2014-07-03 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14051899#comment-14051899 ] Jay Kreps edited comment on KAFKA-1512 at 7/3/14 8:46 PM: -- A

[jira] [Commented] (KAFKA-1519) Console consumer: expose configuration option to enable/disable writing the line separator

2014-07-03 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14051909#comment-14051909 ] Jay Kreps commented on KAFKA-1519: -- I would also vote for supporting an empty separator

[jira] [Commented] (KAFKA-1512) Limit the maximum number of connections per ip address

2014-07-03 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14051951#comment-14051951 ] Jay Kreps commented on KAFKA-1512: -- Yes, I hadn't thought of that. Disabling connections

[jira] [Commented] (KAFKA-1512) Limit the maximum number of connections per ip address

2014-07-03 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14051973#comment-14051973 ] Jay Kreps commented on KAFKA-1512: -- Updated reviewboard

[jira] [Updated] (KAFKA-1512) Limit the maximum number of connections per ip address

2014-07-03 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-1512: - Attachment: KAFKA-1512_2014-07-03_15:17:55.patch Limit the maximum number of connections per ip address

[jira] [Commented] (KAFKA-1519) Console consumer: expose configuration option to enable/disable writing the line separator

2014-07-03 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14052113#comment-14052113 ] Jay Kreps commented on KAFKA-1519: -- Looks good. I think this change might also interpret

[jira] [Commented] (KAFKA-1512) Limit the maximum number of connections per ip address

2014-07-01 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14049117#comment-14049117 ] Jay Kreps commented on KAFKA-1512: -- A couple things to review: 0. The new config is

[jira] [Updated] (KAFKA-1512) Limit the maximum number of connections per ip address

2014-07-01 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-1512: - Attachment: KAFKA-1512.patch Limit the maximum number of connections per ip address

[jira] [Commented] (KAFKA-1512) Limit the maximum number of connections per ip address

2014-07-01 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14049235#comment-14049235 ] Jay Kreps commented on KAFKA-1512: -- Created reviewboard

[jira] [Created] (KAFKA-1512) Limit the maximum number of connections per ip address

2014-06-30 Thread Jay Kreps (JIRA)
Jay Kreps created KAFKA-1512: Summary: Limit the maximum number of connections per ip address Key: KAFKA-1512 URL: https://issues.apache.org/jira/browse/KAFKA-1512 Project: Kafka Issue Type: New

[jira] [Updated] (KAFKA-1512) Limit the maximum number of connections per ip address

2014-06-30 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-1512: - Attachment: KAFKA-1512.patch Limit the maximum number of connections per ip address

[jira] [Commented] (KAFKA-1316) Refactor Sender

2014-06-19 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14037878#comment-14037878 ] Jay Kreps commented on KAFKA-1316: -- Updated reviewboard

[jira] [Updated] (KAFKA-1316) Refactor Sender

2014-06-19 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-1316: - Attachment: KAFKA-1316_2014-06-19_14:01:04.patch Refactor Sender ---

[jira] [Updated] (KAFKA-1291) Make wrapper shell scripts for important tools

2014-06-19 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-1291: - Resolution: Fixed Status: Resolved (was: Patch Available) [~nehanarkhede] I fixed the simple

[jira] [Commented] (KAFKA-1316) Refactor Sender

2014-06-18 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14035911#comment-14035911 ] Jay Kreps commented on KAFKA-1316: -- Ack, this is dumb bug. Thanks! Will patch. Refactor

[jira] [Commented] (KAFKA-1291) Make wrapper shell scripts for important tools

2014-06-18 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14036034#comment-14036034 ] Jay Kreps commented on KAFKA-1291: -- Created reviewboard

[jira] [Updated] (KAFKA-1291) Make wrapper shell scripts for important tools

2014-06-18 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-1291: - Attachment: KAFKA-1291.patch Make wrapper shell scripts for important tools

[jira] [Commented] (KAFKA-1291) Make wrapper shell scripts for important tools

2014-06-18 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14036041#comment-14036041 ] Jay Kreps commented on KAFKA-1291: -- Hey [~sgeller] this is great! I updated this patch a

[jira] [Commented] (KAFKA-1316) Refactor Sender

2014-06-18 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14036582#comment-14036582 ] Jay Kreps commented on KAFKA-1316: -- Created reviewboard

[jira] [Updated] (KAFKA-1316) Refactor Sender

2014-06-18 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-1316: - Attachment: KAFKA-1316.patch Refactor Sender --- Key: KAFKA-1316

[jira] [Resolved] (KAFKA-1316) Refactor Sender

2014-06-11 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-1316. -- Resolution: Fixed Refactor Sender --- Key: KAFKA-1316

[jira] [Commented] (KAFKA-1489) Global threshold on data retention size

2014-06-11 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14028184#comment-14028184 ] Jay Kreps commented on KAFKA-1489: -- Go for it! One slight oddity to consider is this.

[jira] [Commented] (KAFKA-1316) Refactor Sender

2014-06-10 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14027273#comment-14027273 ] Jay Kreps commented on KAFKA-1316: -- Created reviewboard

[jira] [Updated] (KAFKA-1316) Refactor Sender

2014-06-10 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-1316: - Attachment: KAFKA-1316.patch Refactor Sender --- Key: KAFKA-1316

[jira] [Commented] (KAFKA-1316) Refactor Sender

2014-06-10 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14027276#comment-14027276 ] Jay Kreps commented on KAFKA-1316: -- Uploaded patch that has those new APIs. Refactor

[jira] [Commented] (KAFKA-1316) Refactor Sender

2014-06-09 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14025718#comment-14025718 ] Jay Kreps commented on KAFKA-1316: -- Thanks for the feedback Neha: 1. Makes sense, we can

[jira] [Commented] (KAFKA-1316) Refactor Sender

2014-06-09 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14025757#comment-14025757 ] Jay Kreps commented on KAFKA-1316: -- 2. Sure. I guess I don't feel this is necessarily bad

[jira] [Updated] (KAFKA-1316) Refactor Sender

2014-06-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-1316: - Attachment: KAFKA-1316_2014-06-07_11:20:38.patch Refactor Sender ---

[jira] [Commented] (KAFKA-1316) Refactor Sender

2014-06-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14020899#comment-14020899 ] Jay Kreps commented on KAFKA-1316: -- Updated reviewboard

[jira] [Commented] (KAFKA-1316) Refactor Sender

2014-06-07 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14020901#comment-14020901 ] Jay Kreps commented on KAFKA-1316: -- I updated this patch to 1. Address a number of

[jira] [Commented] (KAFKA-1456) Add LZ4 and LZ4C as a compression codec

2014-06-03 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14017133#comment-14017133 ] Jay Kreps commented on KAFKA-1456: -- Guys, does this add a runtime dependency on this jar

[jira] [Commented] (KAFKA-1316) Refactor Sender

2014-06-03 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14017182#comment-14017182 ] Jay Kreps commented on KAFKA-1316: -- Updated reviewboard

[jira] [Updated] (KAFKA-1316) Refactor Sender

2014-06-03 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-1316: - Attachment: KAFKA-1316_2014-06-03_14:33:33.patch Refactor Sender ---

[jira] [Commented] (KAFKA-1316) Refactor Sender

2014-05-28 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14011735#comment-14011735 ] Jay Kreps commented on KAFKA-1316: -- [~guozhang] I think you are describing the case where

[jira] [Commented] (KAFKA-1466) Kafka server is hung after throwing Attempt to swap the new high watermark file with the old one failed

2014-05-28 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14011750#comment-14011750 ] Jay Kreps commented on KAFKA-1466: -- Is it possible you were out of disk space? Here is

[jira] [Commented] (KAFKA-1316) Refactor Sender

2014-05-27 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14010153#comment-14010153 ] Jay Kreps commented on KAFKA-1316: -- Created reviewboard

[jira] [Comment Edited] (KAFKA-1316) Refactor Sender

2014-05-27 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14010498#comment-14010498 ] Jay Kreps edited comment on KAFKA-1316 at 5/27/14 11:38 PM:

[jira] [Commented] (KAFKA-1316) Refactor Sender

2014-05-27 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14010498#comment-14010498 ] Jay Kreps commented on KAFKA-1316: -- For (2) I think there are two solutions 1. Change the

[jira] [Resolved] (KAFKA-1467) Fixes small documentation typos

2014-05-23 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-1467. -- Resolution: Fixed Thanks for the patch! Committed. Fixes small documentation typos

[jira] [Created] (KAFKA-1468) Improve perf tests

2014-05-23 Thread Jay Kreps (JIRA)
Jay Kreps created KAFKA-1468: Summary: Improve perf tests Key: KAFKA-1468 URL: https://issues.apache.org/jira/browse/KAFKA-1468 Project: Kafka Issue Type: Bug Reporter: Jay Kreps

[jira] [Updated] (KAFKA-1468) Improve perf tests

2014-05-23 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-1468: - Attachment: KAFKA-1468.patch Improve perf tests -- Key: KAFKA-1468

[jira] [Commented] (KAFKA-1468) Improve perf tests

2014-05-23 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14007705#comment-14007705 ] Jay Kreps commented on KAFKA-1468: -- Created reviewboard

[jira] [Commented] (KAFKA-1316) Refactor Sender

2014-05-21 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14005249#comment-14005249 ] Jay Kreps commented on KAFKA-1316: -- Neha, yeah I'll post something as I get it in shape.

[jira] [Commented] (KAFKA-1316) Refactor Sender

2014-05-20 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14004009#comment-14004009 ] Jay Kreps commented on KAFKA-1316: -- I started on this and I think I have a design that at

[jira] [Created] (KAFKA-1441) Purgatory purge causes latency spikes

2014-05-16 Thread Jay Kreps (JIRA)
Jay Kreps created KAFKA-1441: Summary: Purgatory purge causes latency spikes Key: KAFKA-1441 URL: https://issues.apache.org/jira/browse/KAFKA-1441 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-1445) New Producer should send all partitions that have non-empty batches when on of them is ready

2014-05-16 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-1445. -- Resolution: Fixed Applied. New Producer should send all partitions that have non-empty batches when

[jira] [Commented] (KAFKA-1445) New Producer should send all partitions that have non-empty batches when on of them is ready

2014-05-16 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13999328#comment-13999328 ] Jay Kreps commented on KAFKA-1445: -- Looks good to me, if no comments from others I will

[jira] [Commented] (KAFKA-1430) Purgatory redesign

2014-05-06 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13990819#comment-13990819 ] Jay Kreps commented on KAFKA-1430: -- The way we garbage collect obsolete entries was

[jira] [Commented] (KAFKA-1430) Purgatory redesign

2014-05-06 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13990829#comment-13990829 ] Jay Kreps commented on KAFKA-1430: -- A couple of random thoughts. - Not sure if I have

[jira] [Commented] (KAFKA-1316) Refactor Sender

2014-05-06 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13991361#comment-13991361 ] Jay Kreps commented on KAFKA-1316: -- Okay so here is my proposal. I want to refactor out a

[jira] [Resolved] (KAFKA-1428) FIS not closed after Properties.load

2014-04-28 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-1428. -- Resolution: Fixed Applied. Nice catch. FIS not closed after Properties.load

<    2   3   4   5   6   7   8   9   10   11   >