Murad M created KAFKA-7930: ------------------------------ Summary: StreamsResetter makes "changelog" topic naming assumptions Key: KAFKA-7930 URL: https://issues.apache.org/jira/browse/KAFKA-7930 Project: Kafka Issue Type: Improvement Components: streams, tools Affects Versions: 2.1.0 Reporter: Murad M
StreamsResetter deletes the topics considered internal. Currently it just checks the naming as per [code|https://github.com/apache/kafka/blob/1aae604861068bb7337d4972c9dcc0c0a99c374d/core/src/main/scala/kafka/tools/StreamsResetter.java#L660]. If assumption is wrong (either topic prefix or suffix), tool becomes useless if aware even dangerous if not. Probably better either: * naming assumption should be optional and supply internal topics with argument (--internal-topics) * deletion could be optional (--no-delete-internal) -- This message was sent by Atlassian JIRA (v7.6.3#76005)