Re: Re: Re: spark2.1 kafka0.10

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

Re: Re: spark2.1 kafka0.10

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> > *抄送

Re: Re: spark2.1 kafka0.10

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

Re: spark2.1 kafka0.10

How many replicas ,you have for this topic . On Thu, Jun 22, 2017 at 9:19 AM, lk_spark wrote: > java.lang.IllegalStateException: No current assignment for partition > pages-2 > at org.apache.kafka.clients.consumer.internals.SubscriptionState. >

Re: spark2.1 kafka0.10

java.lang.IllegalStateException: No current assignment for partition pages-2 at org.apache.kafka.clients.consumer.internals.SubscriptionState.assignedState(SubscriptionState.java:264) at org.apache.kafka.clients.consumer.internals.SubscriptionState.needOffsetReset(SubscriptionState.java:336)