kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Xiangyuan LI <flashmouse2...@gmail.com>
Subject produce very slow after upgrade to 2.3.0
Date Thu, 14 Nov 2019 06:04:37 GMT
hi:
   recently we tried to upgrade our kafka cluster 0.10.0.1 to 2.3.0.
   we know kafka upgrade should:
      1.use 2.3.0.jar and restart  all brokers
      2.unset inter.broker.protocol.version=0.10.0.1 and restart all brokers
      3.unset log.message.format.version=0.10.0.1 and restart all brokers
   we have 15 clusters and most of them have already  complete step 1,2.
   but there are 2 custers left will decrease message produce speed when
all brokers unset inter.broker.protocol.version=0.10.0.1 and restart.
   this cluster has 5 brokers, we
unset  inter.broker.protocol.version=0.10.0.1 and restart all brokers, then
it seems after several minutes , auto leader rebalance triggered, then some
topics' producer decrease their produce speed.
    when this happened:
    1.both client & brokers cpu usage down,memory usage not change
    2.we found ioutil and io bandwidth is very slow ,so it almost
impossible that io
has any performance issue.
   3.we found some consumer group that has large lag before will keep
consume
message without consume speed change,so it seems that consumer
speed not be affected
   4.we found not all topics' produce speed are down. the topic has higest
message
produce speed will decrease certainly  and others are random. we have tried
to
upgrade many times,every time has different topics decrease produce speed.
   5.we only fonud NOT_LEADER_FOR_PARTITION error in producers' log,but it
should be ok when brokers restart. and there are no any error in brokers'
log.
   6. our producer will execute produce.flush() immediately after every
producer.send()
executed. i doubt whether its a big performace effect after we upgrade to
2.3.0?
   7.we have open producers' trace log, we found brokers' response didn't
has
very large latency but send and request num reduce.

  we hope some hint ,thx...

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