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) >> > >
