[
https://issues.apache.org/jira/browse/KAFKA-991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13726891#comment-13726891
]
Jay Kreps commented on KAFKA-991:
-
+1
Reduce the queue size in hadoop
[
https://issues.apache.org/jira/browse/KAFKA-982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-982:
Attachment: 290-screenshot.png
Logo for Kafka
--
Key: KAFKA-982
[
https://issues.apache.org/jira/browse/KAFKA-982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-982:
Attachment: 285-screenshot.png
Logo for Kafka
--
Key: KAFKA-982
[
https://issues.apache.org/jira/browse/KAFKA-982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-982:
Attachment: (was: 290-screenshot.png)
Logo for Kafka
--
Key:
[
https://issues.apache.org/jira/browse/KAFKA-982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-982:
Attachment: 296-screenshot.png
Logo for Kafka
--
Key: KAFKA-982
[
https://issues.apache.org/jira/browse/KAFKA-925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13723074#comment-13723074
]
Jay Kreps commented on KAFKA-925:
-
Good point, type parameter is not needed in
[
https://issues.apache.org/jira/browse/KAFKA-925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-925.
-
Resolution: Fixed
Fix Version/s: 0.8.1
Committed.
Add optional partition key
[
https://issues.apache.org/jira/browse/KAFKA-986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13721095#comment-13721095
]
Jay Kreps commented on KAFKA-986:
-
I can't reproduce this. Here is what I am doing.
I am
[
https://issues.apache.org/jira/browse/KAFKA-982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13721162#comment-13721162
]
Jay Kreps commented on KAFKA-982:
-
Okay so I count
296: 9
298: 10
Everything else: lots
[
https://issues.apache.org/jira/browse/KAFKA-982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13718510#comment-13718510
]
Jay Kreps commented on KAFKA-982:
-
+1 296
Logo for Kafka
--
[
https://issues.apache.org/jira/browse/KAFKA-982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13716601#comment-13716601
]
Jay Kreps commented on KAFKA-982:
-
Not sure that I get 301, what are the pictures? They
[
https://issues.apache.org/jira/browse/KAFKA-982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13717807#comment-13717807
]
Jay Kreps commented on KAFKA-982:
-
Okay, someone just pointed out that 294 is...uh...kind
[
https://issues.apache.org/jira/browse/KAFKA-982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-982:
Attachment: 289.jpeg
Logo for Kafka
--
Key: KAFKA-982
Jay Kreps created KAFKA-982:
---
Summary: Logo for Kafka
Key: KAFKA-982
URL: https://issues.apache.org/jira/browse/KAFKA-982
Project: Kafka
Issue Type: Improvement
Reporter: Jay Kreps
[
https://issues.apache.org/jira/browse/KAFKA-982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-982:
Attachment: 296.png
Logo for Kafka
--
Key: KAFKA-982
[
https://issues.apache.org/jira/browse/KAFKA-982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-982:
Attachment: 298.jpeg
Logo for Kafka
--
Key: KAFKA-982
[
https://issues.apache.org/jira/browse/KAFKA-981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps reassigned KAFKA-981:
---
Assignee: Joe Stein
Joe any idea what this might be?
Unable to pull Kafka binaries
[
https://issues.apache.org/jira/browse/KAFKA-982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-982:
Attachment: 294.jpeg
Logo for Kafka
--
Key: KAFKA-982
[
https://issues.apache.org/jira/browse/KAFKA-982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13715932#comment-13715932
]
Jay Kreps commented on KAFKA-982:
-
No love for 294? I particularly liked that one because
[
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-v2.patch
Updated patch--rebased to trunk.
Add optional partition
[
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-v4.patch
Rebased patch to trunk.
Avoid fsync on log segment roll
[
https://issues.apache.org/jira/browse/KAFKA-925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13711707#comment-13711707
]
Jay Kreps commented on KAFKA-925:
-
Yes the idea of this feature is to make it possible to
[
https://issues.apache.org/jira/browse/KAFKA-925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13711709#comment-13711709
]
Jay Kreps commented on KAFKA-925:
-
It is definitely true that downstream consumers cannot
[
https://issues.apache.org/jira/browse/KAFKA-717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13709855#comment-13709855
]
Jay Kreps commented on KAFKA-717:
-
We are up for switching over at LinkedIn, and will let
[
https://issues.apache.org/jira/browse/KAFKA-717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13709918#comment-13709918
]
Jay Kreps commented on KAFKA-717:
-
Yeah I think we all want to do this, and likely it will
[
https://issues.apache.org/jira/browse/KAFKA-974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13708611#comment-13708611
]
Jay Kreps commented on KAFKA-974:
-
w00t!
can't use public release maven
[
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-v3.patch
Patch version v3:
- Found a call to flush the index in Log.roll(). Removed
[
https://issues.apache.org/jira/browse/KAFKA-943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13706288#comment-13706288
]
Jay Kreps commented on KAFKA-943:
-
I cleaned up the bad config strings I saw in our example
[
https://issues.apache.org/jira/browse/KAFKA-898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13706300#comment-13706300
]
Jay Kreps commented on KAFKA-898:
-
Hey Scott, thanks for the patch!
I think it would be
[
https://issues.apache.org/jira/browse/KAFKA-877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13706302#comment-13706302
]
Jay Kreps commented on KAFKA-877:
-
Is this still happening? If not I want to mark it
[
https://issues.apache.org/jira/browse/KAFKA-836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-836:
Resolution: Fixed
Status: Resolved (was: Patch Available)
Done!
Update
[
https://issues.apache.org/jira/browse/KAFKA-717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13706326#comment-13706326
]
Jay Kreps commented on KAFKA-717:
-
Yeah we can do it in 0.8.1 which should happen fairly
[
https://issues.apache.org/jira/browse/KAFKA-705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13706330#comment-13706330
]
Jay Kreps commented on KAFKA-705:
-
Joel, this is done, no?
Controlled
[
https://issues.apache.org/jira/browse/KAFKA-682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-682.
-
Resolution: Fixed
Marking resolved as we fixed a 0.8 bug that impacted memory and improved the
default
[
https://issues.apache.org/jira/browse/KAFKA-547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-547.
-
Resolution: Fixed
At this point I think we should pass on this for 0.8 since we anyway have it in
trunk.
[
https://issues.apache.org/jira/browse/KAFKA-465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-465.
-
Resolution: Fixed
As mentioned I think this was fixed in KAFKA-425.
Performance test
[
https://issues.apache.org/jira/browse/KAFKA-397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13706352#comment-13706352
]
Jay Kreps commented on KAFKA-397:
-
So is there anything we should be fixing here?
[
https://issues.apache.org/jira/browse/KAFKA-399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-399.
-
Resolution: Won't Fix
0.8 is different enough that I think it is safe to mark this won't fix.
[
https://issues.apache.org/jira/browse/KAFKA-318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13706359#comment-13706359
]
Jay Kreps commented on KAFKA-318:
-
I recommend we just take this on trunk. It will get in
[
https://issues.apache.org/jira/browse/KAFKA-852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-852:
Resolution: Fixed
Status: Resolved (was: Patch Available)
Sorry for lagging on this. Committed.
[
https://issues.apache.org/jira/browse/KAFKA-278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-278.
-
Resolution: Fixed
This should be fixed in 0.8 where we handle partitioning properly.
[
https://issues.apache.org/jira/browse/KAFKA-273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13706377#comment-13706377
]
Jay Kreps commented on KAFKA-273:
-
Is this still happening?
Occassional
[
https://issues.apache.org/jira/browse/KAFKA-242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13706381#comment-13706381
]
Jay Kreps commented on KAFKA-242:
-
Does this bug still exist in 0.8?
[
https://issues.apache.org/jira/browse/KAFKA-877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-877.
-
Resolution: Cannot Reproduce
Will reopen if it reoccurs.
Still getting
[
https://issues.apache.org/jira/browse/KAFKA-898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13706392#comment-13706392
]
Jay Kreps commented on KAFKA-898:
-
We can dump it in contrib, but I think what we have
[
https://issues.apache.org/jira/browse/KAFKA-898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-898:
Resolution: Won't Fix
Status: Resolved (was: Patch Available)
Will be happier elsewhere.
[
https://issues.apache.org/jira/browse/KAFKA-637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-637:
Resolution: Fixed
Assignee: Jay Kreps
Status: Resolved (was: Patch Available)
This is
[
https://issues.apache.org/jira/browse/KAFKA-946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13706465#comment-13706465
]
Jay Kreps commented on KAFKA-946:
-
From Richard:
Sorry, It took a while to remember the
[
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-v2.patch
New patch with a couple of improvements:
1. Found and fixed a bug in
[
https://issues.apache.org/jira/browse/KAFKA-943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13702279#comment-13702279
]
Jay Kreps commented on KAFKA-943:
-
That would work for me.
Move all
[
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-v1.patch
Attached a draft patch for a first version of this for early feedback. A few
[
https://issues.apache.org/jira/browse/KAFKA-943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13699095#comment-13699095
]
Jay Kreps commented on KAFKA-943:
-
Yeah, I think the core disagreement is that we are
[
https://issues.apache.org/jira/browse/KAFKA-960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13699608#comment-13699608
]
Jay Kreps commented on KAFKA-960:
-
Word. I actually think given our experience we might be
[
https://issues.apache.org/jira/browse/KAFKA-943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13698401#comment-13698401
]
Jay Kreps commented on KAFKA-943:
-
Hey Sam, thanks for the patch it is great to get
[
https://issues.apache.org/jira/browse/KAFKA-946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13698427#comment-13698427
]
Jay Kreps commented on KAFKA-946:
-
Ack, well that's broken.
Richard--is this a reasonable
[
https://issues.apache.org/jira/browse/KAFKA-893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13698545#comment-13698545
]
Jay Kreps commented on KAFKA-893:
-
I think this happens if you have the wrong version of
[
https://issues.apache.org/jira/browse/KAFKA-835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13698547#comment-13698547
]
Jay Kreps commented on KAFKA-835:
-
Swapnil, is this still outstanding? If so I can apply...
[
https://issues.apache.org/jira/browse/KAFKA-835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13698548#comment-13698548
]
Jay Kreps commented on KAFKA-835:
-
Also if you could rebase off current site html...
[
https://issues.apache.org/jira/browse/KAFKA-739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-739.
-
Resolution: Fixed
Handle null values in Message payload
-
[
https://issues.apache.org/jira/browse/KAFKA-616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-616.
-
Resolution: Fixed
Assignee: Neha Narkhede
Neha did it :-)
Implement acks=0
[
https://issues.apache.org/jira/browse/KAFKA-555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-555.
-
Resolution: Duplicate
Assignee: Jay Kreps
Did it.
Add a key-based log retention
[
https://issues.apache.org/jira/browse/KAFKA-718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13698576#comment-13698576
]
Jay Kreps commented on KAFKA-718:
-
That would be great.
[
https://issues.apache.org/jira/browse/KAFKA-896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13693249#comment-13693249
]
Jay Kreps commented on KAFKA-896:
-
1. PreferredReplicaLeaderElectionCommand -- this needs
[
https://issues.apache.org/jira/browse/KAFKA-903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13673781#comment-13673781
]
Jay Kreps commented on KAFKA-903:
-
+1
[0.8.0 - windows] FATAL -
[
https://issues.apache.org/jira/browse/KAFKA-905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13671741#comment-13671741
]
Jay Kreps commented on KAFKA-905:
-
This patch looks good. One thing worth pointing out is
Jay Kreps created KAFKA-925:
---
Summary: Add optional partition key override in producer
Key: KAFKA-925
URL: https://issues.apache.org/jira/browse/KAFKA-925
Project: Kafka
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/KAFKA-903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13659805#comment-13659805
]
Jay Kreps commented on KAFKA-903:
-
I don't think this rename functionality is such a good
[
https://issues.apache.org/jira/browse/KAFKA-897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13652041#comment-13652041
]
Jay Kreps commented on KAFKA-897:
-
Yup, I think we are confusing the protocol and the code.
[
https://issues.apache.org/jira/browse/KAFKA-823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13634354#comment-13634354
]
Jay Kreps commented on KAFKA-823:
-
+1 This looks great, thanks for taking the extra time.
[
https://issues.apache.org/jira/browse/KAFKA-823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13628206#comment-13628206
]
Jay Kreps commented on KAFKA-823:
-
I think the second version of the patch is broken. It
[
https://issues.apache.org/jira/browse/KAFKA-649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13626998#comment-13626998
]
Jay Kreps commented on KAFKA-649:
-
+1
A few minor issues:
1. Typo: No broker is ISR is
[
https://issues.apache.org/jira/browse/KAFKA-804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13605568#comment-13605568
]
Jay Kreps commented on KAFKA-804:
-
Also:
- the offsets tuple gets recreated which isnt
[
https://issues.apache.org/jira/browse/KAFKA-804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13602414#comment-13602414
]
Jay Kreps commented on KAFKA-804:
-
I am not sure about this change. There are two choices
[
https://issues.apache.org/jira/browse/KAFKA-805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps reassigned KAFKA-805:
---
Assignee: Jay Kreps
log.append() may fail with a compressed messageset containing no
[
https://issues.apache.org/jira/browse/KAFKA-739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-739:
Attachment: KAFKA-739-v5.patch
Jun, attached v5 patch to address your comments.
40. This is actually right,
[
https://issues.apache.org/jira/browse/KAFKA-554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-554:
Attachment: KAFKA-554-v4.patch
V4 addresses Neha and Jun's comments.
Jun, nice. Made that change.
Neha, I
[
https://issues.apache.org/jira/browse/KAFKA-554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-554.
-
Resolution: Fixed
Assignee: Jay Kreps
Cool, checked in. Jun let me know if you have any further
[
https://issues.apache.org/jira/browse/KAFKA-739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-739:
Attachment: KAFKA-739-v4.patch
Nice catch Sriram, that actually drops the collision rate by 7%.
Here is a
[
https://issues.apache.org/jira/browse/KAFKA-739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-739:
Attachment: KAFKA-739-v4.patch
Nice catch Sriram, that actually drops the collision rate by 7%.
Here is a
[
https://issues.apache.org/jira/browse/KAFKA-554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-554:
Attachment: KAFKA-554-v2.patch
New patch v2. Addresses Jun's comments and rebases.
1. TopicCommand: Made
[
https://issues.apache.org/jira/browse/KAFKA-739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13593523#comment-13593523
]
Jay Kreps commented on KAFKA-739:
-
No, actually it is just git diff against the base
[
https://issues.apache.org/jira/browse/KAFKA-741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-741.
-
Resolution: Duplicate
This issue is fixed in the patch for KAFKA-739. It removes the duplication
using a
[
https://issues.apache.org/jira/browse/KAFKA-554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13592883#comment-13592883
]
Jay Kreps commented on KAFKA-554:
-
Yeah I thought about json vs properties. The advantage i
[
https://issues.apache.org/jira/browse/KAFKA-656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13587423#comment-13587423
]
Jay Kreps commented on KAFKA-656:
-
Yes, that is basic idea. The concern with ewma is just
[
https://issues.apache.org/jira/browse/KAFKA-656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13587466#comment-13587466
]
Jay Kreps commented on KAFKA-656:
-
Yeah this a bit of a dilemma. Doing it cluster-wide with
[
https://issues.apache.org/jira/browse/KAFKA-656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13587997#comment-13587997
]
Jay Kreps commented on KAFKA-656:
-
Yes, it would definitely make sense to use a metric for
[
https://issues.apache.org/jira/browse/KAFKA-208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-208.
-
Resolution: Fixed
This is fixed in the new 0.8 protocol
[
https://issues.apache.org/jira/browse/KAFKA-756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13576705#comment-13576705
]
Jay Kreps commented on KAFKA-756:
-
Ah, I get it. I was wondering about the loop. Usually
[
https://issues.apache.org/jira/browse/KAFKA-755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13576062#comment-13576062
]
Jay Kreps commented on KAFKA-755:
-
Also
c. Think through how any generalization would work
[
https://issues.apache.org/jira/browse/KAFKA-756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13576357#comment-13576357
]
Jay Kreps commented on KAFKA-756:
-
I don't understand the intention of the mutlisend
[
https://issues.apache.org/jira/browse/KAFKA-748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-748.
-
Resolution: Fixed
Checked in.
Jun, I think we effectively do the check you describe already because we
Jay Kreps created KAFKA-754:
---
Summary: Disable log4j logging in command line tools
Key: KAFKA-754
URL: https://issues.apache.org/jira/browse/KAFKA-754
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13573996#comment-13573996
]
Jay Kreps commented on KAFKA-750:
-
Are you sure this is a clean shutdown? Do we have the
[
https://issues.apache.org/jira/browse/KAFKA-748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13574021#comment-13574021
]
Jay Kreps commented on KAFKA-748:
-
This is actually very easy to reproduce. Just do a clean
[
https://issues.apache.org/jira/browse/KAFKA-748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-748:
Attachment: KAFKA-748-v1.patch
Attached is a patch that retains the index position on resize. It also
[
https://issues.apache.org/jira/browse/KAFKA-750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13574094#comment-13574094
]
Jay Kreps commented on KAFKA-750:
-
Item number 1 could actually be caused by KAFKA-748, I
[
https://issues.apache.org/jira/browse/KAFKA-749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13571355#comment-13571355
]
Jay Kreps commented on KAFKA-749:
-
Err, should be
while(true) {
queue.clear()
[
https://issues.apache.org/jira/browse/KAFKA-695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13571427#comment-13571427
]
Jay Kreps commented on KAFKA-695:
-
Can we just remove the interrupt entirely instead of
[
https://issues.apache.org/jira/browse/KAFKA-695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13571427#comment-13571427
]
Jay Kreps commented on KAFKA-695:
-
Can we just remove the interrupt entirely instead of
[
https://issues.apache.org/jira/browse/KAFKA-749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13571585#comment-13571585
]
Jay Kreps commented on KAFKA-749:
-
Also, not sure if I get it. If the I/O threads are able
1001 - 1100 of 1195 matches
Mail list logo
