HBase插入错误:没有协议版本标头

hbase version

<configuration>
  <property>
    <name>hbase.rpc.protection</name>
    <value>privacy</value>
  </property>
  <property>
    <name>hbase.client.protocol.version</name>
    <value>1</value>
  </property>
</configuration>

# 重启HBase集群
$HBASE_HOME/bin/stop-hbase.sh
$HBASE_HOME/bin/start-hbase.sh

# 重启客户端服务
# 根据具体情况重启客户端服务

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.util.Bytes;

public class HBaseInsertExample {
    public static void main(String[] args) throws Exception {
        Configuration config = HBaseConfiguration.create();
        config.set("hbase.zookeeper.quorum", "localhost");
        config.set("hbase.zookeeper.property.clientPort", "2181");
        config.set("hbase.client.protocol.version", "1");

        Connection connection = ConnectionFactory.createConnection(config);
        Table table = connection.getTable(TableName.valueOf("myTable"));

        Put put = new Put(Bytes.toBytes("rowKey"));
        put.addColumn(Bytes.toBytes("cf"), Bytes.toBytes("qualifier"), Bytes.toBytes("value"));

        table.put(put);
        table.close();
        connection.close();
    }
}