Re: Does kafka send the acks response to the producer after flush the messages to the disk or just keep them in the memory

2017-02-28 Thread Jiecxy
nse of the produce request to producer > after it has been replicated (likely in memory) on N partition replicas. > > > Guozhang > > On Sun, Feb 26, 2017 at 1:39 AM, Jiecxy <253441...@qq.com> wrote: > >> Hi guys, >> >>Does kafka send the acks re

Does kafka send the acks response to the producer after flush the messages to the disk or just keep them in the memory

2017-02-26 Thread Jiecxy
Hi guys, Does kafka send the acks response to the producer after flush the messages to the disk or just keep them in the memory? How does Kafka flush the messages? By calling the system call, like fsync()? Thanks Chen

How to measure the load capacity of kafka cluster

2017-02-07 Thread Jiecxy
How to measure the load capacity of one broker or whole cluster? Or maximum throughput? For the quantity of broker, is there any multiple relationship? Such as the capacity of two brokers is twice as much as that of one broker?

The connection between kafka and zookeeper is often closed by zookeeper, lead to NotLeaderForPartitionException: This server is not the leader for that topic-partition.

2016-12-08 Thread Jiecxy
Hi guys, Situation: 3 nodes, each 32G memory, CPU 24 cores, 1T hd. 3 brokers on 3 nodes, and 3 zookeeper on these 3 nodes too, all the properties are default, start the zookeeper cluster and kafka cluster. Create a topic (3 replications, 6 partions), like below: bin/kafka-topics.sh --cr

org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition.

2016-11-22 Thread Jiecxy
Hi all, My kafka version is 2.11_0.10.1.0, and clusters have three nodes. I created a topic (3 replications, 6 partitions). And I tested the class ProducerPerformance by using the command like this: bin/kafka-run-class.sh org.apache.kafka.tools.ProducerPerformance --topic test -