[ 
https://issues.apache.org/jira/browse/KAFKA-17308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872584#comment-17872584
 ] 

Arnab Dutta edited comment on KAFKA-17308 at 8/10/24 1:15 PM:
--------------------------------------------------------------

Bug Identified : 
     The replication fails for specific configs missing synonym updates due to 
load failure on backward compatibility.

Affected Module :
      org.apache.kafka.connect.mirror.DefaultTopicFilter
                                                                           
.TopicFilterConfig
Resolution Needed:    
      Following need to be added at org.apache.kafka.common.utils.ConfigUtils
{code:java}
       public static <T> Map<String, T> translateDeprecatedConfigs(Map<String, 
T> configs, String[][] aliasGroups) {
           return translateDeprecatedConfigs(configs, Stream.of(aliasGroups)
                                                            
.collect(Collectors.toMap(x -> x[0], 
                                                                                
      x -> (List<String>)Stream.of(x).skip(1).collect(Collectors.toList()))));  
     
    }{code}

Project Leader : *Could you Kindly assign it to me plz ?*

 


was (Author: JIRAUSER306451):
Bug Identified : 
     The replication fails for specific configs missing synonym updates due to 
load failure on backward compatibility.

Affected Module :
      org.apache.kafka.connect.mirror.DefaultTopicFilter
                                                                           
.TopicFilterConfig
Resolution Needed:    
      Following need to be added at org.apache.kafka.common.utils.ConfigUtils
{code:java}
       public static <T> Map<String, T> translateDeprecatedConfigs(Map<String, 
T> configs, String[][] aliasGroups) {
           return translateDeprecatedConfigs(configs, Stream.of(aliasGroups)
                                                            
.collect(Collectors.toMap(x -> x[0], 
                                                                                
      x -> (List<String>)Stream.of(x).skip(1).collect(Collectors.toList()))));  
     
    }{code}

Project Leader : *Could you Kindly assign it to me plz ?*

 

> Topic Replication failure :: Config properties exclude should be backwards 
> compatible.
> --------------------------------------------------------------------------------------
>
>                 Key: KAFKA-17308
>                 URL: https://issues.apache.org/jira/browse/KAFKA-17308
>             Project: Kafka
>          Issue Type: Bug
>    Affects Versions: 3.7.1
>            Reporter: Arnab Dutta
>            Priority: Major
>             Fix For: 3.7.1
>
>   Original Estimate: 48h
>  Remaining Estimate: 48h
>
> Observation : 
>       After creating new topic Configuration with SSL under an ALIAS, topic 
> doesn't show up 
>       when filtered by Synonym.
> .



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to