Clean schemas of pseudo topics created when performing a foreign key join

[philipp94831]

Fixes #112

[philipp94831]

While we are at it, I guess isInternalTopic() also needs an update. It looks to me like getExternalSinkTopics() returns the pseudo topics

But the isInternalTopic() and isExternalTopic() method is only applied to the nodes directly as far as I can see and I generate the topics afterwards

• https://github.com/bakdata/streams-bootstrap/blob/fix/clean-pseudo-topics-for-foreign-key-joins/src/main/java/com/bakdata/kafka/util/TopologyInformation.java#L148
• https://github.com/bakdata/streams-bootstrap/blob/fix/clean-pseudo-topics-for-foreign-key-joins/src/main/java/com/bakdata/kafka/util/TopologyInformation.java#L107
• https://github.com/bakdata/streams-bootstrap/blob/fix/clean-pseudo-topics-for-foreign-key-joins/src/main/java/com/bakdata/kafka/util/TopologyInformation.java#L114
• https://github.com/bakdata/streams-bootstrap/blob/fix/clean-pseudo-topics-for-foreign-key-joins/src/main/java/com/bakdata/kafka/util/TopologyInformation.java#L122

[philipp94831]

While we are at it, I guess isInternalTopic() also needs an update. It looks to me like getExternalSinkTopics() returns the pseudo topics

Also in the test I wrote, the getExternalSinkTopics() only returns output