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