It comes from the `repartitionTopicNamePrefix` passed as a parameter when calling `createRepartitionedSource`.
Since we may get an existing repartition topic name, we don't want to append `-repartition` at the end and change it. For example, we may get `KSTREAM-AGGREGATE-STATE-STORE-0000000005-repartition` for a repartition topic name resulting from an optimization operation and appending another `-repartition` would break the topology. As the java docs and our other docs state, we append as single `-repartition` to the repartition topic name we wouldn't want to double append. But I'll update this with a comment explaining why we do this check. [ Full content available at: https://github.com/apache/kafka/pull/5709 ] This message was relayed via gitbox.apache.org for [email protected]
