Hide
I have installed kafa cluster with ambari, but when I update kafka configuration on ambari ui, ambari can not update new version configuration to kafka node.
kafka server.properties and log4j.properties and kafka-env.sh configuration can update successfully, but when I change kafka jaas config (include kafka_jaas_config and kafka_client_jaas_config), it can't overwrite exists jaas config on kafka node.
could you also tell me which script run the configuration compare, which if is not match, it will overwrite the local configuration. I just found out the RecoveryManager.py and ClusterConfig.py and AmbariConfig.py, but all of them I can't see the log info what is "writing file configurationfile , because content don't match".
any help ideas ?? it is so urgent . thanks very much.
Show
I have installed kafa cluster with ambari, but when I update kafka configuration on ambari ui, ambari can not update new version configuration to kafka node.
kafka server.properties and log4j.properties and kafka-env.sh configuration can update successfully, but when I change kafka jaas config (include kafka_jaas_config and kafka_client_jaas_config), it can't overwrite exists jaas config on kafka node.
could you also tell me which script run the configuration compare, which if is not match, it will overwrite the local configuration. I just found out the RecoveryManager.py and ClusterConfig.py and AmbariConfig.py, but all of them I can't see the log info what is "writing file configurationfile , because content don't match".
any help ideas ?? it is so urgent . thanks very much.