[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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.
[
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
[
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
[
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
[
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
[
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
-
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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.
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
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
[
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
[
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
[
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
---
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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.
[
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
[
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
[
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
[
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
[
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
[
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
---
[
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
[
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
[
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
[
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
[
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
---
[
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
[
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
[
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
[
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:
[
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
[
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
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
[
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
[
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
[
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.
[
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
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
[
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
[
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
[
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
[
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
[
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
[
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
601 - 700 of 1195 matches
Mail list logo