0.10.2.0-SNAPSHOT - rocksdb exception(s)

2017-01-01 18:19:13,206 [StreamThread-1] ERROR o.a.k.c.c.i.ConsumerCoordinator - User provided listener org.apache.kafka.streams.processor.internals.StreamThread$1 for group RtDetailBreako utProcessor failed on partition assignment org.apache.kafka.streams.errors.ProcessorStateException: Error op

0.10.2.0-SNAPSHOT - "log end offset should not change while restoring"

java.lang.IllegalStateException: task [0_6] Log end offset of RtDetailBreakoutProcessor-table_stream-changelog-6 should not change while restoring: old end offset 26883455, current offset 2 6883467 at org.apache.kafka.streams.processor.internals.ProcessorStateManager.restoreActiveState(Pr

EOF exceptions - 0.10.2.0-SNAPSHOT

(Ive been testing against the latest from github as 0.10.1.1 is too buggy) Seeing quite a few of these this morning: 2017-01-01 16:56:53,299 [StreamThread-1] DEBUG o.a.kafka.common.network.Selector - Connection with / disconnected java.io.EOFException: null at org.apache.kafka.common.ne