Hello, really helpful article, helps me a lot. found small inaccuracy in this part of code: private def topicPartitionFromString(s: String): Option[TopicPartition] = s.split( "-" ).toList match { case t :: o :: Nil = > o.toIntOption.map { offset = > new TopicPartition(t, offset) } case _ = > None } I suppose instead "offset" it must be partition