[jira] [Updated] (KAFKA-9925) Non-key KTable Joining may result in duplicate schema name in confluence schema registry
[ https://issues.apache.org/jira/browse/KAFKA-9925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kin Siu updated KAFKA-9925: --- Summary: Non-key KTable Joining may result in duplicate schema name in confluence schema registry (was: Non-key KTable Joining result in duplicate schema name in confluence schema registry) > Non-key KTable Joining may result in duplicate schema name in confluence > schema registry > > > Key: KAFKA-9925 > URL: https://issues.apache.org/jira/browse/KAFKA-9925 > Project: Kafka > Issue Type: Bug > Components: streams >Affects Versions: 2.4.1 >Reporter: Kin Siu >Priority: Major > > The second half of issue Andy Bryant reported in KAFKA-9390 looks like still > exist. > When testing non-key join method without passing in "Named", I noticed that > there are schema subjects registered in confluent schema registry without > consumer group Id still, > e.g. > {noformat} > "KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-05-topic-pk-key", > "KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-05-topic-fk-key", > "KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-05-topic-vh-value", > "KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-25-topic-pk-key", > "KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-25-topic-fk-key", > "KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-25-topic-vh-value" > {noformat} > Code in KTableImpl which constructed above naming : > https://github.com/apache/kafka/blob/2.4.1/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java#L959 > When we have multiple topologies using foreignKey join and registered to same > schema registry, we can have a name clash, and fail to register schema. > In order to clean up these schema subjects, we will need to know the internal > naming of a consumer group's topology, which is not straightforward and error > prone. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (KAFKA-9925) Non-key KTable Joining may result in duplicate schema name in confluence schema registry
[ https://issues.apache.org/jira/browse/KAFKA-9925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9925: Fix Version/s: 2.5.1 2.4.2 2.6.0 > Non-key KTable Joining may result in duplicate schema name in confluence > schema registry > > > Key: KAFKA-9925 > URL: https://issues.apache.org/jira/browse/KAFKA-9925 > Project: Kafka > Issue Type: Bug > Components: streams >Affects Versions: 2.4.1 >Reporter: Kin Siu >Assignee: John Roesler >Priority: Major > Fix For: 2.6.0, 2.4.2, 2.5.1 > > > The second half of issue Andy Bryant reported in KAFKA-9390 looks like still > exist. > When testing non-key join method without passing in "Named", I noticed that > there are schema subjects registered in confluent schema registry without > consumer group Id still, > e.g. > {noformat} > "KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-05-topic-pk-key", > "KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-05-topic-fk-key", > "KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-05-topic-vh-value", > "KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-25-topic-pk-key", > "KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-25-topic-fk-key", > "KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-25-topic-vh-value" > {noformat} > Code in KTableImpl which constructed above naming : > https://github.com/apache/kafka/blob/2.4.1/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java#L959 > When we have multiple topologies using foreignKey join and registered to same > schema registry, we can have a name clash, and fail to register schema. > In order to clean up these schema subjects, we will need to know the internal > naming of a consumer group's topology, which is not straightforward and error > prone. -- This message was sent by Atlassian Jira (v8.3.4#803005)