after add broker how to change partition leader to new broker

2017-11-02 Thread lk_kafka
hi,all: on my cluster , some topic Under-replicated 100% , I have 7 broker and the topic have 7 partition ,but the topic now only use 5 broker as leader , how can I chang it to use all the broker as leader ? 2017-11-01 lk_kafka

after add broker how to change partition leader to new broker

2017-10-31 Thread lk_kafka
hi,all: on my cluster , some topic Under-replicated 100% , I have 7 broker and the topic have 7 partition ,but the topic now only use 5 broker as leader , how can I chang it to use all the broker as leader ? 2017-11-01 lk_kafka

kafka0.10 spark2.10

2017-06-21 Thread lk_kafka
(JobGenerator.scala:89) at org.apache.spark.streaming.scheduler.JobGenerator$$anon$1.onReceive(JobGenerator.scala:88) at org.apache.spark.util.EventLoop$$anon$1.run(EventLoop.scala:48) each topic have 5 partition , 2 replicas . I don't know why this error happen. 2017-06-22 lk_kafka