Giter VIP home page Giter VIP logo

Comments (1)

aland-zhang avatar aland-zhang commented on July 30, 2024

I run latest zetcd and kafka using the zetcd .
./bin/kafka-topics.sh -zookeeper 10.10.244.212:2181 -topic test -replication-factor 2 -partitions 3 --create
show info :
[2018-03-16 07:11:43,370] WARN Connected to an old server; r-o mode will be unavailable (org.apache.zookeeper.ClientCnxnSocket)
Created topic "test".

./bin/kafka-producer-perf-test.sh --topic test --throughput 1000000 --num-records 1000000 --producer-props bootstrap.servers=kafka-0.kafka:9092,kafka-1.kafka:9092,kafka-2.kafka:9092 acks=all --record-size 200
71690 records sent, 14338.0 records/sec (2.73 MB/sec), 559.5 ms avg latency, 1412.0 max latency.
113050 records sent, 22610.0 records/sec (4.31 MB/sec), 1092.0 ms avg latency, 3396.0 max latency.
109989 records sent, 21997.8 records/sec (4.20 MB/sec), 1714.5 ms avg latency, 4895.0 max latency.
134212 records sent, 26842.4 records/sec (5.12 MB/sec), 1774.9 ms avg latency, 5201.0 max latency.
131359 records sent, 26271.8 records/sec (5.01 MB/sec), 2766.5 ms avg latency, 7801.0 max latency.

restarted one of In the 3 node kafka cluster show errors:

[2018-03-16 07:26:12,326] WARN [ReplicaFetcherThread-1-3]: Error when sending leader epoch request for Map(test-0 -> 0) (kafka.server.ReplicaFetcherThread)

  | java.io.IOException: Connection to kafka-2.kafka.openshift.svc.cluster.local:9092 (id: 3 rack: null) failed.
  | at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:68)
  | at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:88)
  | at kafka.server.ReplicaFetcherThread.fetchEpochsFromLeader(ReplicaFetcherThread.scala:303)
  | at kafka.server.AbstractFetcherThread.maybeTruncate(AbstractFetcherThread.scala:128)
  | at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:102)
  | at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:64)
  | [2018-03-16 07:26:12,327] INFO [ReplicaFetcherThread-1-3]: Retrying leaderEpoch request for partition test-0 as the leader reported an error: UNKNOWN (kafka.server.ReplicaFetcherThread)
  | [2018-03-16 07:26:12,618] WARN [ReplicaFetcherThread-0-1]: Error when sending leader epoch request for Map(test-2 -> -1) (kafka.server.ReplicaFetcherThread)
  | java.io.IOException: Connection to kafka-0.kafka.openshift.svc.cluster.local:9092 (id: 1 rack: null) failed.
  | at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:68)
  | at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:88)
  | at kafka.server.ReplicaFetcherThread.fetchEpochsFromLeader(ReplicaFetcherThread.scala:303)
  | at kafka.server.AbstractFetcherThread.maybeTruncate(AbstractFetcherThread.scala:128)
  | at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:102)
  | at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:64)
  | [2018-03-16 07:26:12,669] INFO [ReplicaFetcherThread-0-1]: Retrying leaderEpoch request for partition test-2 as the leader reported an error: UNKNOWN (kafka.server.ReplicaFetcherThread)
  | [2018-03-16 07:26:13,379] WARN [ReplicaFetcherThread-1-3]: Error when sending leader epoch request for Map(test-0 -> 0) (kafka.server.ReplicaFetcherThread)
  | java.io.IOException: Connection to kafka-2.kafka.openshift.svc.cluster.local:9092 (id: 3 rack: null) failed.
  | at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:68)
  | at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:88)
  | at kafka.server.ReplicaFetcherThread.fetchEpochsFromLeader(ReplicaFetcherThread.scala:303)
  | at kafka.server.AbstractFetcherThread.maybeTruncate(AbstractFetcherThread.scala:128)
  | at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:102)
  | at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:64)
  | [2018-03-16 07:26:13,380] INFO [ReplicaFetcherThread-1-3]: Retrying leaderEpoch request for partition test-0 as the leader reported an error: UNKNOWN (kafka.server.ReplicaFetcherThread)
  | [2018-03-16 07:26:13,720] WARN [ReplicaFetcherThread-0-1]: Error when sending leader epoch request for Map(test-2 -> -1) (kafka.server.ReplicaFetcherThread)
  | java.io.IOException: Connection to kafka-0.kafka.openshift.svc.cluster.local:9092 (id: 1 rack: null) failed.
  | at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:68)
  | at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:88)
  | at kafka.server.ReplicaFetcherThread.fetchEpochsFromLeader(ReplicaFetcherThread.scala:303)
  | at kafka.server.AbstractFetcherThread.maybeTruncate(AbstractFetcherThread.scala:128)
  | at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:102)
  | at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:64)
  | [2018-03-16 07:26:13,720] INFO [ReplicaFetcherThread-0-1]: Retrying leaderEpoch request for partition test-2 as the leader reported an error: UNKNOWN (kafka.server.ReplicaFetcherThread)

from zetcd.

Related Issues (20)

Recommend Projects

  • React photo React

    A declarative, efficient, and flexible JavaScript library for building user interfaces.

  • Vue.js photo Vue.js

    🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.

  • Typescript photo Typescript

    TypeScript is a superset of JavaScript that compiles to clean JavaScript output.

  • TensorFlow photo TensorFlow

    An Open Source Machine Learning Framework for Everyone

  • Django photo Django

    The Web framework for perfectionists with deadlines.

  • D3 photo D3

    Bring data to life with SVG, Canvas and HTML. 📊📈🎉

Recommend Topics

  • javascript

    JavaScript (JS) is a lightweight interpreted programming language with first-class functions.

  • web

    Some thing interesting about web. New door for the world.

  • server

    A server is a program made to process requests and deliver data to clients.

  • Machine learning

    Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.

  • Game

    Some thing interesting about game, make everyone happy.

Recommend Org

  • Facebook photo Facebook

    We are working to build community through open source technology. NB: members must have two-factor auth.

  • Microsoft photo Microsoft

    Open source projects and samples from Microsoft.

  • Google photo Google

    Google ❤️ Open Source for everyone.

  • D3 photo D3

    Data-Driven Documents codes.