I think the reason is that we do not check for unique names at Grouped / Joined, and hence only when later when the repartition topics are indeed going to be created the exception will be thrown. This looks fine to me.
[ Full content available at: https://github.com/apache/kafka/pull/5709 ] This message was relayed via gitbox.apache.org for [email protected]
