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. > setStateWhenNotInPendingShutdown(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. > ConsumerCoordinator.onJoinComplete(ConsumerCoordinator.java:230) > > at org.apache.kafka.clients.consumer.internals. > AbstractCoordinator.joinGroupIfNeeded(AbstractCoordinator.java:314) > > at org.apache.kafka.clients.consumer.internals. > AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:278) > > at org.apache.kafka.clients.consumer.internals. > ConsumerCoordinator.poll(ConsumerCoordinator.java:261) > > at org.apache.kafka.clients.consumer.KafkaConsumer. > pollOnce(KafkaConsumer.java:1039) > > at org.apache.kafka.clients.consumer.KafkaConsumer.poll( > KafkaConsumer.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) >
errors.log.gz
Description: GNU Zip compressed data
