新网站推广最直接的方法,网站建设课程心得体会,学校网站建设目的是什么,硬件开发平台是什么背景 由物联网项目中使用到了Tbox应用管理车辆#xff0c;在上报数据的过程中#xff0c;需要将终端产生的数据通过kafka的produce topic customer对数据进行处理后#xff0c;放置到mysql中。完成数据二进制到json转换工作。
Kafka的使用
查看kafka的topic
./kafka-topi…
背景 由物联网项目中使用到了Tbox应用管理车辆在上报数据的过程中需要将终端产生的数据通过kafka的produce topic customer对数据进行处理后放置到mysql中。完成数据二进制到json转换工作。
Kafka的使用
查看kafka的topic
./kafka-topics --bootstrap-server 10.1.9.84:9092 --list
查看topic信息
./kafka-topics --bootstrap-server 10.1.9.84:9092 --describe --topic topic_example_1
创建topic 创建topic名为test分区数为8副本数为1
./kafka-topics.sh --create --zookeeper 10.128.106.52:2181 --topic test --partitions 8 --replication-factor 1
修改topic
./kafka-topics.sh --zookeeper 10.128.106.52:2181 -alter --partitions 12 --topic test
删除topic
./kafka-topics.sh --zookeeper 10.128.106.52:2181 --delete --topic test 消费者
kafka-console-consumer.sh --bootstrap-server 10.1.9.84:9092 --topic topic_example_1
消费者-group
./kafka-consumer-groups.sh --bootstrap-server 10.1.9.84:9092 --list
消费者-指定group
./kafka-consumer-groups.sh --bootstrap-server 10.1.9.84:9092 --group ai-trace --describe
生产者
kafka-console-producer.sh --broker-list 10.1.9.84:9092 --topic topic_example_1 查看消费者性能
./kafka-consumer-perf-test.sh --broker-list 10.1.9.84:9092 --messages 500000
--topic test-topic
查看生产者性能
./kafka-producer-perf-test.sh --topic test-topic --num-records 500000
--record-size 200 --throughput -1 --producer-props bootstrap.servers10.1.9.84:9092 acks-1
kafka关键要素
produce topic customer
生产者
kafka-console-producer.sh --broker-list 10.1.9.84:9092 --topic topic_example_1
消费者
kafka-console-consumer.sh --bootstrap-server 10.1.9.84:9092 --topic topic_example_1
kafka在jmeter 中的使用
kafka_brokersKafka_topicKafka_meassage
以上三个属性对于kafka来讲都很重要
消费者
kafka-console-consumer.sh --bootstrap-server 10.1.9.84:9092 --topic topic_example_1 kubectl中查看指定pod的日志
找到指定应用
Kubectl get pods -n cdb | grep dst(pods名称)
查看日志工具 kubectl logs -n cdb guoyin-dst-gianhai-netty-time-cdb-92-644c895b8d-bnnw2
