sudo -i
su sudo -i

hive认证:

kinit -kt /etc/security/keytabs/hive.headless.keytab hive@DATA.NET
hive

hbase认证:

kinit -kt /etc/security/keytabs/hbase.headless.keytab hbase@DATA.NET
hbase shell

kafka认证:

使用klist检查keytab

klist -kte  /etc/security/keytabs/kafka.service.keytab
kinit -kt /etc/security/keytabs/kafka.service.keytab kafka/ip@用户.NET

查看topic列表

kafka-topics.sh --bootstrap-server ip:9092 --list --command-config /etc/kafka/conf/kafka_client.properties

新建topic

kafka-topics.sh --bootstrap-server ip:9092 --create --topic test0113 --partitions 1 --replication-factor 1 --command-config /etc/kafka/conf/kafka_client.properties

生产者窗口写数据

kafka-console-producer.sh --bootstrap-server ip:9092 --topic counts --producer.config /etc/kafka/conf/kafka_client.properties

kafka测试数据示例

{"id": 1,"tinyint_test": -112,"smallint_test": 30694,"age": -112,"bigint_test": 92595912232238367,"float_test": 10.123,"double_test": 10.1234567,"decimal_test": 10.0123456789,"varchar_test": "丰盛1","char_test": "x1","sex_test": "男","symbol": "男","rowtime": "2025-12-17 17:13:32.618","price": 17,"tax": 1,"date_test": "2025-12-17","datetime_test": "2025-12-17 17:13:32","time_test": "17:13:32.626","fdatetime_test": "2025-12-17 17:13:32.626","timestamp_test": "1765962812626","boolean_test": "true","namex": "f1_q","name": "f1_"}

读取counts 数据

kafka-console-consumer.sh --bootstrap-server ​​​​​​​ip:9092 --topic counts --consumer.config /etc/kafka/conf/kafka_client.properties

从头开始读取所有历史数据,读取完成后5秒自动退出

kafka-console-consumer.sh --bootstrap-server ip:9092 --topic counts --consumer.config /etc/kafka/conf/kafka_client.properties --from-beginning --timeout-ms 5000

Logo

腾讯云面向开发者汇聚海量精品云计算使用和开发经验,营造开放的云计算技术生态圈。

更多推荐