KafkaExecutor suffers from an open issue in the current Alpakka-Kafka release. Revoking partitions causes offsets to be skipped. https://github.com/akka/alpakka-kafka/issues/382