Comments (1)
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)
- [Feature] sd_notify for systemd notification
- [Question/Feature] Etcd base key for zk schema
- 4 letter word commands leaking memory
- zookeeper exception, KeeperErrorCode = apiError
- GetChildren doesn't get children HOT 1
- Why separate keys for each metadata parameter?
- zetcd ha
- Kafka Unable to connect to zookeeper server
- How to build the project source code after change it?
- when zetcd should release v1.0.0? and is it have any tool to migrate data from zk to etcd?
- Need a new release to get rid of known vulnerabilities in the latest image HOT 1
- Performance benchmarking
- go get error:gcc_darwin_amd64.c:62:15: error: unknown token in expression HOT 1
- Proposal to mark etcd-io/zetc as public archive HOT 7
- etcd3 STM client does not Support Range fetch over keys? HOT 1
- zetcd performance HOT 3
- New version/future plans? HOT 2
- Memory/leak issue HOT 9
- ZK MultiOp provided by zetcd not working with Kafka 2.1.0 HOT 1
- Mtime and Ctime off by a factor of 1000 HOT 1
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
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.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from zetcd.