[
https://issues.apache.org/jira/browse/KAFKA-693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maxime Brugidou updated KAFKA-693:
--
Attachment: KAFKA-693-v3.patch
Added v3 with your remarks
> Consumer rebalance
Posted a couple of comments on the wiki.
Thanks,
Jun
On Wed, Jan 16, 2013 at 8:18 PM, Jay Kreps wrote:
> I added a first pass at a proposal for moving topic configuration into
> zookeeper so that you would specify the config when you created the topic
> and config could be altered without boun
Using separate ZK paths for replicas assignment and configs seems better
since it allows each of them to be updated independently. Yes, we should
make a path of values stored in ZK for future extension. Could you file a
jira?
Thanks,
Jun
On Wed, Jan 16, 2013 at 7:47 PM, Jay Kreps wrote:
> Why
We also did some perf test on 0.8 using the following command. All configs
on the broker are the defaults.
bin/kafka-run-class.sh kafka.perf.ProducerPerformance --broker-list
localhost:9092 --initial-message-id 0 --messages 200 --topics topic_001
--request-num-acks -1 --batch-size 100 --threads
This will be a useful feature to have. Posted few thoughts on an
alternative implementation.
Thanks,
Neha
On Thu, Jan 17, 2013 at 7:56 AM, Jun Rao wrote:
> Posted a couple of comments on the wiki.
>
> Thanks,
>
> Jun
>
> On Wed, Jan 16, 2013 at 8:18 PM, Jay Kreps wrote:
>
> > I added a first
Looks like Jun's email didn't format the output properly. I've published
some preliminary producer throughput performance numbers on our performance
wiki -
https://cwiki.apache.org/confluence/display/KAFKA/Performance+testing#Performancetesting-Producerthroughput
These tests measure producer throu
[
https://issues.apache.org/jira/browse/KAFKA-691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13556380#comment-13556380
]
Jun Rao commented on KAFKA-691:
---
Actually, the current code works since partitionId is always
[
https://issues.apache.org/jira/browse/KAFKA-693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-693:
--
Resolution: Fixed
Fix Version/s: 0.8
Status: Resolved (was: Patch Available)
Thanks for the p
Issue Subscription
Filter: outstanding kafka patches (61 issues)
The list of outstanding kafka patches
Subscriber: kafka-mailing-list
Key Summary
KAFKA-709 Default queue.enqueue.timeout.ms to -1
https://issues.apache.org/jira/browse/KAFKA-709
KAFKA-708 ISR becomes e
John Fung created KAFKA-710:
---
Summary: Some arguments are always set to default in
ProducerPerformance
Key: KAFKA-710
URL: https://issues.apache.org/jira/browse/KAFKA-710
Project: Kafka
Issue Type
[
https://issues.apache.org/jira/browse/KAFKA-710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13556565#comment-13556565
]
John Fung commented on KAFKA-710:
-
The following arguments are always set to default values
[
https://issues.apache.org/jira/browse/KAFKA-710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Fung updated KAFKA-710:
Attachment: kafka-710-v1.patch
Uploaded kafka-710-v1.patch to remove the additional variables
[
https://issues.apache.org/jira/browse/KAFKA-710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Fung updated KAFKA-710:
Status: Patch Available (was: Open)
> Some arguments are always set to default in ProducerPerformance
>
I defined a customized partitioner:
class ExpertSearchCollectionPartitioner implements Partitioner {
@Override
public int partition(Long key, int numPartitions) {
System.out.print("partition: " + key + ", " + numPartitions +
", "+ (key.hashCode() % numPartitions) +
"\n");
retur
producer.num.acks=-1 means what sorry? is it that all replica's are written
too?
On Thu, Jan 17, 2013 at 12:09 PM, Neha Narkhede wrote:
> Looks like Jun's email didn't format the output properly. I've published
> some preliminary producer throughput performance numbers on our performance
> wiki
Hi Jane,
This error is
java.lang.NoSuchMethodException:
com.twitter.expertsearch.indexing.jit.ExpertSearchCollectionPartitio
ner.(kafka.utils.VerifiableProperties)
It means that you need to have a constructor which takes a single argument,
VerifiableProperties. This is a way to pass any configura
I also tried with the constructor
ExpertSearchCollectionPartitioner(VerifiableProperties props) {
}
Still the same error.
I also tried the constructor without any parameter and with parameter Long.
None of them worked.
On Thu, Jan 17, 2013 at 7:08 PM, Jay Kreps wrote:
> Hi Jane,
>
> This e
[
https://issues.apache.org/jira/browse/KAFKA-260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13556958#comment-13556958
]
Felix GV commented on KAFKA-260:
It would be possible to have optional timestamps by using
I means wait for the data reaches all replicas (that are in sync).
Thanks,
Jun
On Thu, Jan 17, 2013 at 6:42 PM, S Ahmed wrote:
> producer.num.acks=-1 means what sorry? is it that all replica's are written
> too?
>
>
> On Thu, Jan 17, 2013 at 12:09 PM, Neha Narkhede >wrote:
>
> > Looks like Ju
[
https://issues.apache.org/jira/browse/KAFKA-709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13556973#comment-13556973
]
Jay Kreps commented on KAFKA-709:
-
+1
> Default queue.enqueue.timeout.ms t
[
https://issues.apache.org/jira/browse/KAFKA-707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13556974#comment-13556974
]
Jay Kreps commented on KAFKA-707:
-
What is the resulting error the user will see in this ca
[
https://issues.apache.org/jira/browse/KAFKA-682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13556975#comment-13556975
]
Jay Kreps commented on KAFKA-682:
-
Yes, Joel, that makes sense. Ricky, do you know the "ack
[
https://issues.apache.org/jira/browse/KAFKA-709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede closed KAFKA-709.
---
> Default queue.enqueue.timeout.ms to -1
> --
>
>
[
https://issues.apache.org/jira/browse/KAFKA-709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-709:
Status: Patch Available (was: In Progress)
> Default queue.enqueue.timeout.ms to -1
> -
[
https://issues.apache.org/jira/browse/KAFKA-709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-709:
Resolution: Fixed
Status: Resolved (was: Patch Available)
Thanks for the review
[
https://issues.apache.org/jira/browse/KAFKA-709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-709 started by Neha Narkhede.
> Default queue.enqueue.timeout.ms to -1
> --
>
> Key: KAFKA-709
>
[
https://issues.apache.org/jira/browse/KAFKA-707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13556979#comment-13556979
]
Neha Narkhede commented on KAFKA-707:
-
[2013-01-17 21:41:19,151] WARN Failed to send da
27 matches
Mail list logo
