thank you Kumar , I will try it later.
2017-06-22
lk_spark
发件人：Pralabh Kumar
发送时间：2017-06-22 20:20
主题：Re: Re: spark2.1 kafka0.10
收件人："lk_spark"
抄送："user.spark"
It looks like your replicas for partition are getting failed. If u have more
brokers , can u try increasin
017-06-22
> --
> lk_spark
> --
>
> *发件人：*Pralabh Kumar
> *发送时间：*2017-06-22 17:23
> *主题：*Re: spark2.1 kafka0.10
> *收件人：*"lk_spark"
> *抄送：*"user.spark"
>
> How many replicas ,you have for thi
each topic have 5 partition , 2 replicas .
2017-06-22
lk_spark
发件人：Pralabh Kumar
发送时间：2017-06-22 17:23
主题：Re: spark2.1 kafka0.10
收件人："lk_spark"
抄送："user.spark"
How many replicas ,you have for this topic .
On Thu, Jun 22, 2017 at 9:19
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.
> assignedState(SubscriptionState.java:264)
> at or
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)
a
