如果是连接安全集群，在启动kafka manager之前先做以下几件事情 1. 修改kafka服务端，将allow.everyone.if.no.acl.found配置成true。原因是Kafka Manager会调用SimpleConsumer API去获取每个consumer的offset，新SimpleConsumer的API不支持认证，即需要开启不认证也能消费。 2. 导出环境变量 export JAVA_OPTS="-Djava.security.auth.login.config=/opt/kafka-manager-1.3.3.17/conf/jaas.conf -Dzookeeper.server.principal=zookeeper/hadoop.hadoop.com -Djava.security.krb5.conf=/opt/huawei/Bigdata/MRS_1.7.0/etc/1_4_KerberosClient/kdc.conf -Dzookeeper.request.timeout=120000 -Dkerberos.domain.name=hadoop.hadoop.com" 注意将路径和kerberos.domain.name替换成实际值

本帖最后由 石头剪刀布 于 2018-6-5 16:00 编辑如果是安全集群，首先第一步是配置互信，请参考这个连接： https://support.huaweicloud.com/usermanual-mrs/mrs_01_0354.html 另外 distcp的时候带上参数 -prbugpcaxt 即使用此命令distcp： hadoop distcp -i -prbugpcaxt hdfs://node-master1-rbufh:25000/hbase/data hdfs://hacluster/hbase hadoop distcp –update –append –delete -prbugpcaxt hdfs://node-master1-rbufh:25000/hbase/ hdfs://hacluster/hbase/

{:4_87:}{:4_87:}{:4_87:}

好用~ 为Kafka提供了一些方便的界面操作~ {:4_87:}

{:4_87:}{:4_87:}{:4_87:}