Within the Kafka Stream topology, internal topic are created. For this internal topics, schema avro for key and value are registered into schema registry.
For the topic internal-MYAPPS-KSTREAM-KEY-SELECT-0000000099-repartition, I have 2 subjects into schema registry : - internal-MYAPPS-KSTREAM-KEY-SELECT-0000000099-repartition-key - internal-MYAPPS-KSTREAM-KEY-SELECT-0000000099-repartition-value My questions are : How Kafka create the internal topology name (how the suffix number is changed) ? When if I change the processing into the toplogy => change in the DAG ? - If I have a name with 0000000099, do I have the same number after a modification of the topology ? - If not, is Kafka Stream allowed to use an already used number ? I ask this question because I have an incompatible schema on an internal topic and from my point of view, no changes have been made on the schema. The only change is a modification on the topology which change the DAG and maybe the name of internal topic. Thanks for your time, Cédric
