Closed myloverwdm closed 9 months ago
我对比了TopicConfigServiceImpl,BrokerConfigServiceImpl,这两个文件中的处理方法,和KafkaConfigConverer中convert2KafkaBrokerConfigDetailList,convert2KafkaTopicConfigDetailList 我的理解getBrokerConfigByZKClient中new ArrayList()的入参替换成kafka broker 的配置列表,处理方式是否是这里来处理的?
我对比了TopicConfigServiceImpl,BrokerConfigServiceImpl,这两个文件中的处理方法,和KafkaConfigConverer中convert2KafkaBrokerConfigDetailList,convert2KafkaTopicConfigDetailList 我的理解getBrokerConfigByZKClient中new ArrayList()的入参替换成kafka broker 的配置列表,处理方式是否是这里来处理的?
是的
维护成类似TopicConfig0100这种配置的类信息?但是没找到相关BrokerConfig相关的信息?是否有指引类?
我理解应该是把配置的key值作为参数传入,如果是的这个问题我来处理吧
在getBrokerConfigByZKClient方法中,调用KafkaConfigConverter.convert2KafkaBrokerConfigDetailList,传递第一个参数为空列表,KafkaConfigConverter.convert2KafkaBrokerConfigDetailList方法中对该列表进行遍历,然后返回,而参数为空列表是写死的,故该方法一定返回空列表,且KafkaConfigConverter.convert2KafkaBrokerConfigDetailList方法仅有该处使用到。
另:getBrokerConfigByZKClient方法中的代码: for (Object key: properties.keySet()) { properties.getProperty((String) key); } 不清楚该代码的目的是什么。校验所有的key都要是String类型,若不是String则强转失败吗?与之相同问题的还有TopicConfigServiceImpl类中的getTopicConfigByZKClient方法