def partitionToKey()

in kafka/src/main/scala/org/apache/pekko/projection/kafka/KafkaOffsets.scala [35:42]

• 7 lines of code
• 3 McCabe index (conditional complexity)

  def partitionToKey(topic: String, partition: Int): String = topic + separator + partition
  def partitionToKey(tp: TopicPartition): String = partitionToKey(tp.topic(), tp.partition())

  def keyToPartition(key: String): TopicPartition = key match {
    case RegexTp(topic, partition) => new TopicPartition(topic, partition.toInt)
    case _ =>
      throw new IllegalArgumentException(s"Row entry name ($key) must match pattern: ${RegexTp.pattern.toString}")
  }