K - so no big deal. TY
On Fri, Dec 30, 2016 at 12:13 PM, Ewen Cheslack-Postava <[email protected]> wrote: > Jon, > > This looks the same as https://issues.apache.org/jira/browse/KAFKA-4563, > although for a different invalid transition. The temporary fix suggested > there is to simply convert the exception to log a warning, which should be > a pretty trivial patch against trunk. It seems there are some transitions > that haven't fully been thought through even if they may actually be valid, > so patching this for now may be the easiest way to unblock your > development. > > -Ewen > > On Fri, Dec 30, 2016 at 9:45 AM, Jon Yeargers <[email protected]> > wrote: > > > Attaching the debug log > > > > On Fri, Dec 30, 2016 at 6:39 AM, Jon Yeargers <[email protected]> > > wrote: > > > >> Using 0.10.2.0-snapshot: > >> > >> java.lang.IllegalStateException: Incorrect state transition from > >> ASSIGNING_PARTITIONS to ASSIGNING_PARTITIONS > >> > >> at org.apache.kafka.streams.processor.internals.StreamThread. > >> setState(StreamThread.java:163) > >> > >> at org.apache.kafka.streams.processor.internals.StreamThread.se > >> tStateWhenNotInPendingShutdown(StreamThread.java:175) > >> > >> at org.apache.kafka.streams.processor.internals.StreamThread. > >> access$200(StreamThread.java:71) > >> > >> at org.apache.kafka.streams.processor.internals.StreamThread$1. > >> onPartitionsAssigned(StreamThread.java:234) > >> > >> at org.apache.kafka.clients.consumer.internals.ConsumerCoordina > >> tor.onJoinComplete(ConsumerCoordinator.java:230) > >> > >> at org.apache.kafka.clients.consumer.internals.AbstractCoordina > >> tor.joinGroupIfNeeded(AbstractCoordinator.java:314) > >> > >> at org.apache.kafka.clients.consumer.internals.AbstractCoordina > >> tor.ensureActiveGroup(AbstractCoordinator.java:278) > >> > >> at org.apache.kafka.clients.consumer.internals.ConsumerCoordina > >> tor.poll(ConsumerCoordinator.java:261) > >> > >> at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce( > >> KafkaConsumer.java:1039) > >> > >> at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaCo > >> nsumer.java:1004) > >> > >> at org.apache.kafka.streams.processor.internals.StreamThread. > >> runLoop(StreamThread.java:569) > >> > >> at org.apache.kafka.streams.processor.internals.StreamThread. > >> run(StreamThread.java:358) > >> > > > > >
