thank you Kumar , I will try it later.
2017-06-22
lk_spark
发件人：Pralabh Kumar <pralabhku...@gmail.com>
发送时间：2017-06-22 20:20
主题：Re: Re: spark2.1 kafka0.10
收件人："lk_spark"<lk_sp...@163.com>
抄送："user.spark"<user@spark.apache.org>
It looks like your rep
replicas .
>
> 2017-06-22
> --
> lk_spark
> --
>
> *发件人：*Pralabh Kumar <pralabhku...@gmail.com>
> *发送时间：*2017-06-22 17:23
> *主题：*Re: spark2.1 kafka0.10
> *收件人：*"lk_spark"<lk_sp...@163.com>
> *抄送
each topic have 5 partition , 2 replicas .
2017-06-22
lk_spark
发件人：Pralabh Kumar <pralabhku...@gmail.com>
发送时间：2017-06-22 17:23
主题：Re: spark2.1 kafka0.10
收件人："lk_spark"<lk_sp...@163.com>
抄送："user.spark"<user@spark.apache.org>
How many replicas ,you h
e.spark.streaming.scheduler.JobGenerator$$anon$
> 1.onReceive(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)
>
> 2017-06-22
>
)
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)
2017-06-22
lk_spark
发件人："lk_spark"<lk_sp...@163.com>
发送时间：2017-06-22 11:13
主题：spark2.1 kafka0.10
收件人："user.spark"<user@spark.apache.org>
抄送：
hi,all
hi,all:
when I run stream application for a few minutes ,I got this error :
17/06/22 10:34:56 INFO ConsumerCoordinator: Revoking previously assigned
partitions [comment-0, profile-1, profile-3, cwb-3, bizs-1, cwb-1,
weibocomment-0, bizs-2, pages-0, bizs-4, pages-2, weibo-0, pages-4, weibo-4,
