title: Failed to rebalance error in Kafka Streams with more than one topic partition
body: <p>Works fine when source topic partition count = 1. If I bump up the partitions to any value > 1, I see the below error. Applicable to both Low level as well as the DSL API. Any pointers ? What could be missing ?</p>
  
  <pre><code>org.apache.kafka.streams.errors.StreamsException: stream-thread [StreamThread-1] Failed to rebalance
          at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:410)
          at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:242)
  
  Caused by: org.apache.kafka.streams.errors.StreamsException: task [0_1] Store in-memory-avg-store's change log (cpu-streamz-in-memory-avg-store-changelog) does not contain partition 1
          at org.apache.kafka.streams.processor.internals.ProcessorStateManager.register(ProcessorStateManager.java:185)
          at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.register(ProcessorContextImpl.java:123)
          at org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreSupplier$MemoryStore.init(InMemoryKeyValueStoreSupplier.java:102)
          at org.apache.kafka.streams.state.internals.InMemoryKeyValueLoggedStore.init(InMemoryKeyValueLoggedStore.java:56)
          at org.apache.kafka.streams.state.internals.MeteredKeyValueStore.init(MeteredKeyValueStore.java:85)
          at org.apache.kafka.streams.processor.internals.AbstractTask.initializeStateStores(AbstractTask.java:81)
          at org.apache.kafka.streams.processor.internals.StreamTask.&lt;init&gt;(StreamTask.java:119)
          at org.apache.kafka.streams.processor.internals.StreamThread.createStreamTask(StreamThread.java:633)
          at org.apache.kafka.streams.processor.internals.StreamThread.addStreamTasks(StreamThread.java:660)
          at org.apache.kafka.streams.processor.internals.StreamThread.access$100(StreamThread.java:69)
          at org.apache.kafka.streams.processor.internals.StreamThread$1.onPartitionsAssigned(StreamThread.java:124)
          at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.onJoinComplete(ConsumerCoordinator.java:228)
          at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.joinGroupIfNeeded(AbstractCoordinator.java:313)
          at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:277)
          at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:259)
          at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1013)
          at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:979)
          at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:407)
  </code></pre>