[
https://issues.apache.org/jira/browse/KAFKA-1241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13894188#comment-13894188
]
Jay Kreps commented on KAFKA-1241:
--
I improved the error for that case. I think the
[
https://issues.apache.org/jira/browse/KAFKA-1171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13890828#comment-13890828
]
Jay Kreps commented on KAFKA-1171:
--
My impression is that people who use Scala have
[
https://issues.apache.org/jira/browse/KAFKA-1171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13889696#comment-13889696
]
Jay Kreps commented on KAFKA-1171:
--
Shouldn't we default to scala 2.9 or something newer
[
https://issues.apache.org/jira/browse/KAFKA-1238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-1238:
-
Attachment: KAFKA-1238.patch
Fix attached.
New producer hangs in a loop detecting metadata for auto
[
https://issues.apache.org/jira/browse/KAFKA-1227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-1227:
-
Attachment: KAFKA-1227.patch
Code dump of new producer
-
[
https://issues.apache.org/jira/browse/KAFKA-1227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13889247#comment-13889247
]
Jay Kreps commented on KAFKA-1227:
--
Created reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-1227:
-
Attachment: KAFKA-1227.patch
Code dump of new producer
-
[
https://issues.apache.org/jira/browse/KAFKA-1227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13883481#comment-13883481
]
Jay Kreps commented on KAFKA-1227:
--
Hey Edward,
What I actually want for the Cluster
[
https://issues.apache.org/jira/browse/KAFKA-1229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13882439#comment-13882439
]
Jay Kreps commented on KAFKA-1229:
--
The problem with doing this in general beyond the
Jay Kreps created KAFKA-1227:
Summary: Code dump of new producer
Key: KAFKA-1227
URL: https://issues.apache.org/jira/browse/KAFKA-1227
Project: Kafka
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/KAFKA-1227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13880343#comment-13880343
]
Jay Kreps commented on KAFKA-1227:
--
Created reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-1227:
-
Attachment: KAFKA-1227.patch
Code dump of new producer
-
[
https://issues.apache.org/jira/browse/KAFKA-1227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13880717#comment-13880717
]
Jay Kreps commented on KAFKA-1227:
--
Hey Jun, quick responses. I'll try to get a patch up
[
https://issues.apache.org/jira/browse/KAFKA-1227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13880752#comment-13880752
]
Jay Kreps commented on KAFKA-1227:
--
Hey Guozhang, thanks for the detailed stylistic
[
https://issues.apache.org/jira/browse/KAFKA-1171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13846415#comment-13846415
]
Jay Kreps commented on KAFKA-1171:
--
These build discussions tend to blow up due to the
[
https://issues.apache.org/jira/browse/KAFKA-1137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13828487#comment-13828487
]
Jay Kreps commented on KAFKA-1137:
--
One thing to be aware of is that we process requests
[
https://issues.apache.org/jira/browse/KAFKA-1112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13825708#comment-13825708
]
Jay Kreps commented on KAFKA-1112:
--
Yeah at a high-level there are a couple of things we
[
https://issues.apache.org/jira/browse/KAFKA-1112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13825922#comment-13825922
]
Jay Kreps commented on KAFKA-1112:
--
+1 lgtm.
broker can not start itself after kafka is
[
https://issues.apache.org/jira/browse/KAFKA-1112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13823822#comment-13823822
]
Jay Kreps commented on KAFKA-1112:
--
David, this should not be happening in 0.8. If it is
[
https://issues.apache.org/jira/browse/KAFKA-1112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13823829#comment-13823829
]
Jay Kreps commented on KAFKA-1112:
--
Jun, this is true.
However, if you think about it
[
https://issues.apache.org/jira/browse/KAFKA-1112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-1112:
-
Attachment: KAFKA-1112-v3.patch
Okay here is a maximally paranoid patch.
broker can not start itself
[
https://issues.apache.org/jira/browse/KAFKA-1112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13824068#comment-13824068
]
Jay Kreps commented on KAFKA-1112:
--
Yeah I would not be opposed to that as an
[
https://issues.apache.org/jira/browse/KAFKA-1130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13820222#comment-13820222
]
Jay Kreps commented on KAFKA-1130:
--
Fair enough. If we are going to make the change let's
[
https://issues.apache.org/jira/browse/KAFKA-1112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-1112:
-
Attachment: KAFKA-1112-v1.patch
The way the check was supposed to work was this: if the last offset in
[
https://issues.apache.org/jira/browse/KAFKA-1130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13819810#comment-13819810
]
Jay Kreps commented on KAFKA-1130:
--
I agree this is a tad bit ambiguous. However the
[
https://issues.apache.org/jira/browse/KAFKA-1132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13819811#comment-13819811
]
Jay Kreps commented on KAFKA-1132:
--
Surely this is just for 0.8.1, no?
Any change we
[
https://issues.apache.org/jira/browse/KAFKA-1119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13813655#comment-13813655
]
Jay Kreps commented on KAFKA-1119:
--
Hmm, but it looks like the current behavior is to
[
https://issues.apache.org/jira/browse/KAFKA-1106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13808133#comment-13808133
]
Jay Kreps commented on KAFKA-1106:
--
Do you have the highwatermark checkpoint file that
[
https://issues.apache.org/jira/browse/KAFKA-1098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-1098:
-
Attachment: KAFKA-1098-v3.patch
Ack, fixed 2.10 issue. Frustrating. Do we have a single sbt command that
[
https://issues.apache.org/jira/browse/KAFKA-1098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-1098.
--
Resolution: Fixed
Unit test failure in 0.8.1 related to LogCleaner
[
https://issues.apache.org/jira/browse/KAFKA-1098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-1098:
-
Attachment: KAFKA-1098-v2.patch
Here is a patch that seems to fix the issue.
Unit test failure in
[
https://issues.apache.org/jira/browse/KAFKA-1098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13802606#comment-13802606
]
Jay Kreps commented on KAFKA-1098:
--
Sorry about the churn btw I was only compiling for
[
https://issues.apache.org/jira/browse/KAFKA-1042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-1042:
-
Attachment: KAFKA-1042-v2.patch
Rebased that patch with minor changes.
Also I found a subtle problem
[
https://issues.apache.org/jira/browse/KAFKA-1042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-1042.
--
Resolution: Fixed
Fix segment flush logic
---
Key: KAFKA-1042
[
https://issues.apache.org/jira/browse/KAFKA-1081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-1081.
--
Resolution: Fixed
Checked in on both 0.8 and trunk.
kafka-run-class.sh is broken
[
https://issues.apache.org/jira/browse/KAFKA-1036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-1036.
--
Resolution: Fixed
Checked in fix on trunk. Note that I don't have access to a windows box so I
can't
[
https://issues.apache.org/jira/browse/KAFKA-1008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-1008.
--
Resolution: Fixed
Checked in on 0.8 and trunk.
Unmap before resizing
-
[
https://issues.apache.org/jira/browse/KAFKA-1081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13792936#comment-13792936
]
Jay Kreps commented on KAFKA-1081:
--
Yeah I agree, rerunning the command to get the error
Jay Kreps created KAFKA-1085:
Summary: run-class.sh and other shell scripts are copy pasted all
over the place
Key: KAFKA-1085
URL: https://issues.apache.org/jira/browse/KAFKA-1085
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-1081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-1081:
-
Attachment: KAFKA-1081-v1.patch
Here is a proposed patch that uses exec for all the main commands and
[
https://issues.apache.org/jira/browse/KAFKA-1008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-1008:
-
Attachment: KAFKA-1008-v9-trunk.patch
Attached KAFKA-1008-v9-trunk.patch which ports the final 0.8 patch
[
https://issues.apache.org/jira/browse/KAFKA-369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13789801#comment-13789801
]
Jay Kreps commented on KAFKA-369:
-
I guess all distributed systems have a problem of
[
https://issues.apache.org/jira/browse/KAFKA-1076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13787416#comment-13787416
]
Jay Kreps commented on KAFKA-1076:
--
+1
system tests in 0.8 are broken due to wrong
[
https://issues.apache.org/jira/browse/KAFKA-982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-982.
-
Resolution: Fixed
Logo for Kafka
--
Key: KAFKA-982
URL:
Jay Kreps created KAFKA-1070:
Summary: Auto-assign node id
Key: KAFKA-1070
URL: https://issues.apache.org/jira/browse/KAFKA-1070
Project: Kafka
Issue Type: Bug
Reporter: Jay Kreps
[
https://issues.apache.org/jira/browse/KAFKA-1070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-1070:
-
Description: It would be nice to have Kafka brokers auto-assign node ids
rather than having that be a
[
https://issues.apache.org/jira/browse/KAFKA-1070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13784113#comment-13784113
]
Jay Kreps commented on KAFKA-1070:
--
I think the right way to do this is to have a
[
https://issues.apache.org/jira/browse/KAFKA-1008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-1008:
-
Attachment: KAFKA-0.8-1008-v8.patch
Unmap before resizing
-
[
https://issues.apache.org/jira/browse/KAFKA-1036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13773527#comment-13773527
]
Jay Kreps commented on KAFKA-1036:
--
I'm a little confused. I don't see any file locking
[
https://issues.apache.org/jira/browse/KAFKA-1008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13773503#comment-13773503
]
Jay Kreps commented on KAFKA-1008:
--
Sriram:
1.1 This is because this.mmap can be null so
[
https://issues.apache.org/jira/browse/KAFKA-1008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13773504#comment-13773504
]
Jay Kreps commented on KAFKA-1008:
--
Jun, added private on that method. Not sure about
[
https://issues.apache.org/jira/browse/KAFKA-1008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13773503#comment-13773503
]
Jay Kreps edited comment on KAFKA-1008 at 9/20/13 10:17 PM:
[
https://issues.apache.org/jira/browse/KAFKA-1043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13771557#comment-13771557
]
Jay Kreps commented on KAFKA-1043:
--
Why not just configure the socket buffer size based
[
https://issues.apache.org/jira/browse/KAFKA-1056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13769664#comment-13769664
]
Jay Kreps commented on KAFKA-1056:
--
Agreed. This becomes a problem in the case where
[
https://issues.apache.org/jira/browse/KAFKA-1050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13762070#comment-13762070
]
Jay Kreps commented on KAFKA-1050:
--
Hey Justin, yeah the two things I wanted to clarify:
[
https://issues.apache.org/jira/browse/KAFKA-1049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13762193#comment-13762193
]
Jay Kreps commented on KAFKA-1049:
--
I agree that an init() method avoids the
[
https://issues.apache.org/jira/browse/KAFKA-1050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13761528#comment-13761528
]
Jay Kreps commented on KAFKA-1050:
--
I think there may be some confusion. Does this
[
https://issues.apache.org/jira/browse/KAFKA-1050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13761530#comment-13761530
]
Jay Kreps commented on KAFKA-1050:
--
Or actually, perhaps I am confused. The data loss
[
https://issues.apache.org/jira/browse/KAFKA-1024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13752578#comment-13752578
]
Jay Kreps commented on KAFKA-1024:
--
Interesting
possible memory
[
https://issues.apache.org/jira/browse/KAFKA-1026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13752577#comment-13752577
]
Jay Kreps commented on KAFKA-1026:
--
This is a good idea, but I recommend we put this off
[
https://issues.apache.org/jira/browse/KAFKA-1008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-1008:
-
Attachment: KAFKA-0.8-1008-v7.patch
Attached a version rebased to 0.8.
Unmap before
[
https://issues.apache.org/jira/browse/KAFKA-1023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13751715#comment-13751715
]
Jay Kreps commented on KAFKA-1023:
--
My recommendation is just to increase the retention.
[
https://issues.apache.org/jira/browse/KAFKA-1024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13751723#comment-13751723
]
Jay Kreps commented on KAFKA-1024:
--
Your serialized message size is 2KB, perhaps but I
[
https://issues.apache.org/jira/browse/KAFKA-955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13750375#comment-13750375
]
Jay Kreps commented on KAFKA-955:
-
Great fix. A few minor comments, mostly stylistic.
[
https://issues.apache.org/jira/browse/KAFKA-1024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13750470#comment-13750470
]
Jay Kreps commented on KAFKA-1024:
--
64MB is a really small heap. Can you validate that
[
https://issues.apache.org/jira/browse/KAFKA-1024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13750681#comment-13750681
]
Jay Kreps commented on KAFKA-1024:
--
Yes.
possible memory leak in 0.8
[
https://issues.apache.org/jira/browse/KAFKA-925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-925:
Attachment: KAFKA-925-post-commit-v1.patch
Yeah fair point. I didn't realize we had a special infinity
[
https://issues.apache.org/jira/browse/KAFKA-1023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13749738#comment-13749738
]
Jay Kreps commented on KAFKA-1023:
--
Yeah I would also be reticent to do this. The reason
[
https://issues.apache.org/jira/browse/KAFKA-1000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-1000:
-
Description:
Kafka currently stores offsets in zookeeper. This is a problem for several
reasons. First
[
https://issues.apache.org/jira/browse/KAFKA-1008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-1008:
-
Attachment: KAFKA-1008-v6.patch
Hey Elizabeth, this basically looks good. A couple of minor things.
One
[
https://issues.apache.org/jira/browse/KAFKA-1008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13741035#comment-13741035
]
Jay Kreps commented on KAFKA-1008:
--
Yeah, the problem is reads continue while the log is
[
https://issues.apache.org/jira/browse/KAFKA-1008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13741037#comment-13741037
]
Jay Kreps commented on KAFKA-1008:
--
Here is a list of os.name values (at least according
[
https://issues.apache.org/jira/browse/KAFKA-1008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13740611#comment-13740611
]
Jay Kreps commented on KAFKA-1008:
--
But my understanding is that these copies are just
[
https://issues.apache.org/jira/browse/KAFKA-1008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13739197#comment-13739197
]
Jay Kreps commented on KAFKA-1008:
--
Hey Elizabeth, thanks for the patch.
Two issues.
[
https://issues.apache.org/jira/browse/KAFKA-718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-718:
Resolution: Fixed
Fix Version/s: 0.8
Assignee: Jay Kreps (was: Neha Narkhede)
[
https://issues.apache.org/jira/browse/KAFKA-615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13729684#comment-13729684
]
Jay Kreps commented on KAFKA-615:
-
1.1 Good catch
2.1 My desire is to ensure that
[
https://issues.apache.org/jira/browse/KAFKA-615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13729700#comment-13729700
]
Jay Kreps commented on KAFKA-615:
-
Jun.
52.2 In most filesystems there is no guarantee
[
https://issues.apache.org/jira/browse/KAFKA-615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-615:
Attachment: KAFKA-615-v7.patch
Patch which uses the correct but slow approach of synchronously committing
[
https://issues.apache.org/jira/browse/KAFKA-615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-615:
Attachment: KAFKA-615-v8.patch
Ack, yes, I did mean to fix the recoveryPoint/logEndOffset issue, I just
Jay Kreps created KAFKA-1001:
Summary: Handle follower transition in batch
Key: KAFKA-1001
URL: https://issues.apache.org/jira/browse/KAFKA-1001
Project: Kafka
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/KAFKA-615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13730155#comment-13730155
]
Jay Kreps commented on KAFKA-615:
-
Also, Jun, basic system tests all pass with v8.
[
https://issues.apache.org/jira/browse/KAFKA-615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13730154#comment-13730154
]
Jay Kreps commented on KAFKA-615:
-
Filed KAFKA-1001 to handle the follow-up work to
[
https://issues.apache.org/jira/browse/KAFKA-615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-615.
-
Resolution: Fixed
Fix Version/s: 0.8.1
Assignee: Jay Kreps (was: Neha Narkhede)
Ah, nice
[
https://issues.apache.org/jira/browse/KAFKA-615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-615:
Attachment: KAFKA-615-v6.patch
Updated patch:
- Removed bad scaladoc
- Improved log corruption test to
[
https://issues.apache.org/jira/browse/KAFKA-718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-718:
Attachment: KAFKA-718-v5.patch
Patch v5: move all logs to a logs/ directory to avoid polluting the main
[
https://issues.apache.org/jira/browse/KAFKA-718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13729076#comment-13729076
]
Jay Kreps commented on KAFKA-718:
-
Sorry, I had missed that file in v4. I had fixed it in
[
https://issues.apache.org/jira/browse/KAFKA-615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13729087#comment-13729087
]
Jay Kreps commented on KAFKA-615:
-
Ah thanks for the detailed review:
50.2 Yes, nice.
50.3
[
https://issues.apache.org/jira/browse/KAFKA-527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13728575#comment-13728575
]
Jay Kreps commented on KAFKA-527:
-
The general idea of the refactoring would be to allow
[
https://issues.apache.org/jira/browse/KAFKA-996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13728577#comment-13728577
]
Jay Kreps commented on KAFKA-996:
-
+1 but can we apply this on trunk? We are trying to
[
https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13728583#comment-13728583
]
Jay Kreps commented on KAFKA-992:
-
This is good, this can go on trunk, right?
[
https://issues.apache.org/jira/browse/KAFKA-995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-995:
Fix Version/s: 0.8.1
Enforce that the value for replica.fetch.max.bytes is always = the value for
[
https://issues.apache.org/jira/browse/KAFKA-995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13728585#comment-13728585
]
Jay Kreps commented on KAFKA-995:
-
Committed on trunk.
Enforce that the
[
https://issues.apache.org/jira/browse/KAFKA-985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-985.
-
Resolution: Fixed
Fix Version/s: (was: 0.9)
0.8.1
Ack, nice catch.
[
https://issues.apache.org/jira/browse/KAFKA-984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13728597#comment-13728597
]
Jay Kreps commented on KAFKA-984:
-
Guys I don't think we should be doing massive surgery on
[
https://issues.apache.org/jira/browse/KAFKA-718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-718:
Attachment: KAFKA-718-v4.patch
New patch. Rebased. Fixed logging in tools so that we no longer spew crazy
[
https://issues.apache.org/jira/browse/KAFKA-527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-527:
Description:
The data path for compressing or decompressing messages is extremely
inefficient. We do
[
https://issues.apache.org/jira/browse/KAFKA-527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-527:
Attachment: java.hprof.no-compression.txt
Compression support does numerous byte copies
[
https://issues.apache.org/jira/browse/KAFKA-527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13728452#comment-13728452
]
Jay Kreps commented on KAFKA-527:
-
To test performance checkout trunk and do
./sbt package
[
https://issues.apache.org/jira/browse/KAFKA-615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-615:
Attachment: KAFKA-615-v5.patch
Attach updated patch v5. Rebased against trunk and with added support for
[
https://issues.apache.org/jira/browse/KAFKA-994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13726536#comment-13726536
]
Jay Kreps commented on KAFKA-994:
-
Ack, nice catch.
High level consumer
901 - 1000 of 1195 matches
Mail list logo
