>Cannot follow here... Do you aim for existing topologies with generated names, >and user update code to "pin" names? For this case, user would pass it name, >without -repartition suffix? User, would also need to drop <application.id> >prefix in the name she passed to Grouped.
>I cannot follow here too.. the createRepartitionedSource should always be >called before the optimization kicks in, so the passed in name should always >be the raw names right? @mjsax @guozhangwang As we are re-using the repartition topic name when optimizing checking for the `-repartition` suffix was done during those cases when re-using the topic name which is already formatted with `appId-baseName-repartition` I have since cleaned up the code and re-use the topic name in the `InternalStreamsBuilder` when performing the optimization. [ Full content available at: https://github.com/apache/kafka/pull/5709 ] This message was relayed via gitbox.apache.org for [email protected]
