Skip to content

Reset internal topics#40

Merged
torbsto merged 5 commits intomasterfrom
feature/reset-internal-topics
Dec 11, 2019
Merged

Reset internal topics#40
torbsto merged 5 commits intomasterfrom
feature/reset-internal-topics

Conversation

@torbsto
Copy link
Copy Markdown
Contributor

@torbsto torbsto commented Nov 26, 2019

This PR adds resetting subjects of internal topics. It iterates over the topology to get the corresponding names. Additionally, it extracts the clean up in a separate class and adds the deletion of manually created topics, that are not output or error topic (e.g. used for through)

Comment thread src/main/java/com/bakdata/common_kafka_streams/CleanUpRunner.java Outdated
Comment thread src/main/java/com/bakdata/common_kafka_streams/CleanUpRunner.java Outdated
Comment thread src/main/java/com/bakdata/common_kafka_streams/CleanUpRunner.java Outdated
Comment thread src/main/java/com/bakdata/common_kafka_streams/CleanUpRunner.java Outdated
@torbsto torbsto merged commit 1d5c286 into master Dec 11, 2019
@torbsto torbsto deleted the feature/reset-internal-topics branch December 11, 2019 08:59
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants