kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jinxing <jinxing6...@126.com>
Subject kafka callback issuekk
Date Tue, 08 Sep 2015 09:52:05 GMT
hi, all

im testing kafka- using ASYNC producer;

I have two processes, each process have 20 threads to send messages, the testing time is 10

the message is random UUID;

the result is as below:

I called "producer.send(producerRecord, callback)" 2200191 times;
the "callback" is called 1624178 times;
I use bin/kafka-consumer-offset-checker.sh and find that log size increased by 1648994;

it seems:         sendTimes>logSizeIncrease>callbacks

Is it reasonable?

I mean from the client, producer got no error or exception, but the message failed to be appended
to the kafka queue?

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message