[
https://issues.apache.org/jira/browse/KAFKA-2039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14390168#comment-14390168
]
Ismael Juma commented on KAFKA-2039:
Is there anything I can do to help move this
Thanks!
Yeah, the shutdown hook will run on a separate thread.
In that case, I don't need (or want) to keep acceptors in
ConcurrentHashMap - we are either starting up or shutting down a
broker, but don't want to do both at same time.
I'll just synchronize the acceptors startup and shutdown in
[
https://issues.apache.org/jira/browse/KAFKA-2073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14390783#comment-14390783
]
Sriharsha Chintalapani commented on KAFKA-2073:
---
[~gwenshap] are you
[
https://issues.apache.org/jira/browse/KAFKA-2074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14390780#comment-14390780
]
Sriharsha Chintalapani commented on KAFKA-2074:
---
[~gwenshap] are you
Geoffrey,
One thing I want to consider in re-writing the system tests is
the ability to run these on other OS not just linux. If we
can support both linux and windows that will be great. I am
not sure how much of that work will be involved on the
Thanks for confirming :)
On Wed, Apr 1, 2015 at 8:42 AM, Jun Rao j...@confluent.io wrote:
Yes, I was able to run the system tests on mac, after enabling ssh.
Thanks,
Jun
On Tue, Mar 31, 2015 at 6:00 PM, Gwen Shapira gshap...@cloudera.com wrote:
Hi,
The first line of the system_test
[
https://issues.apache.org/jira/browse/KAFKA-2073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14390801#comment-14390801
]
Sriharsha Chintalapani commented on KAFKA-2073:
---
Thanks :) [~gwenshap]
Yes. That sounds good. It also fixes the visibility of processors, which
seems to have a potential issue now.
Thanks,
Jun
On Tue, Mar 31, 2015 at 11:25 PM, Gwen Shapira gshap...@cloudera.com
wrote:
Thanks!
Yeah, the shutdown hook will run on a separate thread.
In that case, I don't need
[
https://issues.apache.org/jira/browse/KAFKA-2073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sriharsha Chintalapani reassigned KAFKA-2073:
-
Assignee: Sriharsha Chintalapani
Replace TopicMetadata request/response
[
https://issues.apache.org/jira/browse/KAFKA-2074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sriharsha Chintalapani reassigned KAFKA-2074:
-
Assignee: Sriharsha Chintalapani
Add UpdateMetadata request/response to
[
https://issues.apache.org/jira/browse/KAFKA-2073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14390790#comment-14390790
]
Gwen Shapira commented on KAFKA-2073:
-
Take as many of these as you want, my friend. I
Yes, I was able to run the system tests on mac, after enabling ssh.
Thanks,
Jun
On Tue, Mar 31, 2015 at 6:00 PM, Gwen Shapira gshap...@cloudera.com wrote:
Hi,
The first line of the system_test README says:
This test framework currently doesn't support MacOS due to different
ps argument
Jun Rao created KAFKA-2086:
--
Summary: testRoundRobinPartitionAssignor transient failure
Key: KAFKA-2086
URL: https://issues.apache.org/jira/browse/KAFKA-2086
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-2082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14392017#comment-14392017
]
Evan Huus commented on KAFKA-2082:
--
I have pushed another branch called
[
https://issues.apache.org/jira/browse/KAFKA-2082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14391877#comment-14391877
]
Evan Huus commented on KAFKA-2082:
--
The 3GB is only set if you use VMware fusion, if you
[
https://issues.apache.org/jira/browse/KAFKA-1926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14391999#comment-14391999
]
Tong Li commented on KAFKA-1926:
[~junrao]Thanks so much for the quick review. All the new
[
https://issues.apache.org/jira/browse/KAFKA-2082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Evan Huus updated KAFKA-2082:
-
Description:
While running integration tests for Sarama (the go client) we came across a
pattern of
See https://builds.apache.org/job/KafkaPreCommit/50/changes
Changes:
[junrao] kafka-2013; benchmark test for the purgatory; patched by Yasuhiro
Matsuda; reviewed by Jun Rao
--
[...truncated 2090 lines...]
kafka.admin.DeleteTopicTest
[
https://issues.apache.org/jira/browse/KAFKA-2013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-2013:
---
Resolution: Fixed
Fix Version/s: 0.8.3
Status: Resolved (was: Patch Available)
Thanks for
See https://builds.apache.org/job/Kafka-trunk/438/changes
Changes:
[junrao] kafka-2013; benchmark test for the purgatory; patched by Yasuhiro
Matsuda; reviewed by Jun Rao
--
[...truncated 2229 lines...]
kafka.message.MessageWriterTest
[
https://issues.apache.org/jira/browse/KAFKA-1926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14391990#comment-14391990
]
Tong Li commented on KAFKA-1926:
Updated reviewboard https://reviews.apache.org/r/32740/
[
https://issues.apache.org/jira/browse/KAFKA-1926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tong Li updated KAFKA-1926:
---
Attachment: KAFKA-1926_2015-04-01_22:16:46.patch
Replace kafka.utils.Utils with o.a.k.common.utils.Utils
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/30809/#review78630
---
Thanks for the patch. A few high level comments.
1. I think we are
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/32740/
---
(Updated April 2, 2015, 2:16 a.m.)
Review request for kafka.
Bugs:
[
https://issues.apache.org/jira/browse/KAFKA-2078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14391970#comment-14391970
]
Jun Rao commented on KAFKA-2078:
Do you see ZK session timeout on the broker? With large
[
https://issues.apache.org/jira/browse/KAFKA-2078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14392123#comment-14392123
]
Aravind edited comment on KAFKA-2078 at 4/2/15 4:30 AM:
Hi Jun,
[
https://issues.apache.org/jira/browse/KAFKA-2078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14392123#comment-14392123
]
Aravind commented on KAFKA-2078:
Hi Jun,
There is no ZK session timeout on the broker. I
[
https://issues.apache.org/jira/browse/KAFKA-2064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Holoman reassigned KAFKA-2064:
---
Assignee: Jeff Holoman
Replace ConsumerMetadataRequest and Response with
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14390958#comment-14390958
]
Jiangjie Qin commented on KAFKA-1660:
-
[~jkreps] Ping to see if you could help review
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/31568/#review78444
---
Thanks for the patch! A few comments below.
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/32740/
---
Review request for kafka.
Bugs: KAFKA-1926
[
https://issues.apache.org/jira/browse/KAFKA-1926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14391295#comment-14391295
]
Tong Li commented on KAFKA-1926:
[~junrao], all comments have been addressed in the latest
[
https://issues.apache.org/jira/browse/KAFKA-1929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14391298#comment-14391298
]
Jeff Holoman commented on KAFKA-1929:
-
[~jkreps] Did you have a chance to review this?
[
https://issues.apache.org/jira/browse/KAFKA-1926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tong Li updated KAFKA-1926:
---
Attachment: KAFKA-1926.patch
Replace kafka.utils.Utils with o.a.k.common.utils.Utils
On March 29, 2015, 7:33 p.m., Jun Rao wrote:
core/src/main/scala/kafka/server/KafkaConfig.scala, lines 345-347
https://reviews.apache.org/r/28769/diff/21/?file=908381#file908381line345
It seems that a 3-digit value like 0.8.2 is also valid?
Gwen Shapira wrote:
yes, and also
[
https://issues.apache.org/jira/browse/KAFKA-2082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14391517#comment-14391517
]
Sriharsha Chintalapani commented on KAFKA-2082:
---
[~eapache] did a quick look
See https://builds.apache.org/job/KafkaPreCommit/49/changes
Changes:
[junrao] kafka-2039; Update Scala to 2.10.5 and 2.11.6; patched by Ismael Juma;
reviewed by Jun Rao
--
[...truncated 2111 lines...]
java.net.BindException: Address already in use
Jun Rao created KAFKA-2081:
--
Summary: testUncleanLeaderElectionEnabledByTopicOverride transient
failure
Key: KAFKA-2081
URL: https://issues.apache.org/jira/browse/KAFKA-2081
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-2039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-2039:
---
Resolution: Fixed
Fix Version/s: 0.8.3
Assignee: Ismael Juma
Status: Resolved
On April 1, 2015, 6:46 p.m., Jun Rao wrote:
core/src/main/scala/kafka/server/DelayedOperation.scala, line 126
https://reviews.apache.org/r/31568/diff/2/?file=901425#file901425line126
timeoutTimer is an implementation detail in ExpiredOperationReaper.
Could we hide it inside
[
https://issues.apache.org/jira/browse/KAFKA-1989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14391422#comment-14391422
]
Yasuhiro Matsuda commented on KAFKA-1989:
-
Updated reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yasuhiro Matsuda updated KAFKA-1989:
Attachment: KAFKA-1989_2015-04-01_13:49:58.patch
New purgatory design
[
https://issues.apache.org/jira/browse/KAFKA-2082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Evan Huus updated KAFKA-2082:
-
Description:
While running integration tests for Sarama (the go client) we came across a
pattern of
[
https://issues.apache.org/jira/browse/KAFKA-2082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Evan Huus updated KAFKA-2082:
-
Description:
While running integration tests for Sarama (the go client) we came across a
pattern of
[
https://issues.apache.org/jira/browse/KAFKA-2082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Evan Huus updated KAFKA-2082:
-
Description:
While running integration tests for Sarama (the go client) we came across a
pattern of
[
https://issues.apache.org/jira/browse/KAFKA-2082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Evan Huus updated KAFKA-2082:
-
Description:
While running integration tests for Sarama (the go client) we came across a
pattern of
[
https://issues.apache.org/jira/browse/KAFKA-2078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14391618#comment-14391618
]
Aravind commented on KAFKA-2078:
Also getting few of Connection timed out errors my
Hey everyone,
I've made changes to the KIP to capture our discussions over the last couple of
weeks.
https://cwiki.apache.org/confluence/display/KAFKA/KIP-13+-+Quotas
I'll start a voting thread after people have had a chance to read/comment.
Thanks,
Aditya
Aditya Auradkar created KAFKA-2083:
--
Summary: Quotas for Kafka
Key: KAFKA-2083
URL: https://issues.apache.org/jira/browse/KAFKA-2083
Project: Kafka
Issue Type: New Feature
Aditya Auradkar created KAFKA-2084:
--
Summary: byte rate metrics per client ID (producer and consumer)
Key: KAFKA-2084
URL: https://issues.apache.org/jira/browse/KAFKA-2084
Project: Kafka
Aditya Auradkar created KAFKA-2085:
--
Summary: Return delay time in QuotaViolationException
Key: KAFKA-2085
URL: https://issues.apache.org/jira/browse/KAFKA-2085
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-2079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14391680#comment-14391680
]
Joe Stein commented on KAFKA-2079:
--
I think if we do this (which we should) the work
[
https://issues.apache.org/jira/browse/KAFKA-2082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14391699#comment-14391699
]
Sriharsha Chintalapani commented on KAFKA-2082:
---
[~eapache] I am having hard
53 matches
Mail list logo