![\"image.png\"](\"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d7b0c913a08637a697f46\/2-0.png\" "\\"\\"")
<\/div>\n\u6211\u5c06\u4f7f\u7528\u4ee5\u4e0b\u4e24\u4e2a\u6b65\u9aa4\u6309\u987a\u5e8f\u89e3\u91ca\u4e0a\u8ff0\u5185\u5bb9\u3002\u8fd9\u6b21\u6211\u5c06\u89e3\u91ca\u7b2c2\u6b65\u3002
\n\u7b2c1\u6b65\uff1a\u5728AKS\u4e0a\u90e8\u7f72Confluent Platform\u73af\u5883
\n\u7b2c2\u6b65\uff1a\u5728AKS\u4e0a\u8fd0\u884c\u5bb9\u5668\u5e94\u7528\u7a0b\u5e8f<\/p>\n
\u672c\u5730\u73af\u5883<\/h2>\n
macOS Big Sur 11.3: \u82f9\u679c\u64cd\u4f5c\u7cfb\u7edfBig Sur 11.3
\nPython 3.8.3: Python 3.8.3
\nHelm 3.6.3: Helm 3.6.3<\/p>\n
\u4e8b\u524d\u51c6\u5907<\/h2>\n\n- \n
\u53c2\u8003\u306b\u3057\u3066\u3001\u5df2\u7ecf\u642d\u5efa\u597d\u4e86AKS\u548cACR\uff0c\u5e76\u4e14\u5df2\u7ecf\u786e\u8ba4\u5728AKS\u96c6\u7fa4\u4e0a\u8fd0\u884c\u7684\u8282\u70b9\u3002<\/ol>\n<\/li>\n<\/ol>\n\u53c2\u8003\u6b64\u6587\u7ae0\uff0c\u5c06\u5bb9\u5668\u955c\u50cf\u63a8\u9001\u5230ACR\u3002<\/p>\n
\u786e\u8ba4\u5728\u6b64\u6587\u7ae0\u4e2d\u5df2\u7ecf\u5b8c\u6210\u4e86\u201cHelm\u51c6\u5907\u201d\u3002<\/p>\n
\n\u5c06\u8bbe\u5b9a\u4f20\u9001\u5230Pod<\/h2>\n\u786e\u8ba4Pod<\/h3>\n$ kubectl get pod -n akscp01\r\n\r\nNAME READY STATUS RESTARTS AGE\r\ncp600-cp-control-center-5b55c5676f-tn5w9 1\/1 Running 3 3m46s\r\ncp600-cp-kafka-0 2\/2 Running 1 3m46s\r\ncp600-cp-kafka-1 2\/2 Running 0 3m8s\r\ncp600-cp-kafka-2 2\/2 Running 0 2m46s\r\ncp600-cp-kafka-connect-764c9bd6cd-n84qw 2\/2 Running 3 3m46s\r\ncp600-cp-ksql-server-5948c75b8b-dnfcm 2\/2 Running 4 3m46s\r\ncp600-cp-schema-registry-5d79b8c57-r4r5p 2\/2 Running 3 3m46s\r\ncp600-cp-zookeeper-0 2\/2 Running 0 3m46s\r\ncp600-cp-zookeeper-1 2\/2 Running 0 3m8s\r\ncp600-cp-zookeeper-2 2\/2 Running 0 2m32s\r\ncp600db-influxdb-5ff9b5cfbc-zkvjb 1\/1 Running 0 33m\r\ncp600gf-grafana-59cff8f44b-rwlwx 1\/1 Running 0 13m\r\ncp600mq-rabbitmq-0 1\/1 Running 0 6m22s\r\n<\/code><\/pre>\n
\n\u521b\u5efa Kafka \u4e3b\u9898<\/h3>\n## Kafka-client \u3078\u306e\u63a5\u7d9a\r\n$ kubectl exec -it kafka-client -n akscp01 -- \/bin\/bash\r\n\r\n## \u74b0\u5883\u5909\u6570\u306e\u5b9a\u7fa9\r\n$ export RELEASE_NAME=cp600\r\n$ export ZOOKEEPERS=${RELEASE_NAME}-cp-zookeeper:2181\r\n\r\n## topic_201 \/ topic_202 \u306e\u4f5c\u6210\r\n$ kafka-topics --zookeeper $ZOOKEEPERS --create --topic topic_201 --partitions 3 --replication-factor 1\r\n$ kafka-topics --zookeeper $ZOOKEEPERS --create --topic topic_202 --partitions 3 --replication-factor 1\r\n\r\n## topic \u306e\u78ba\u8a8d\r\n$ kafka-topics --zookeeper $ZOOKEEPERS --list\r\n<\/code><\/pre>\n
\nKSQL \u7684\u914d\u7f6e<\/h3>\n## Ksql-client \u3078\u306e\u63a5\u7d9a\r\n$ kubectl exec -it ksql-client -n akscp01 -- \/bin\/bash\r\n\r\n## \u74b0\u5883\u5909\u6570\u306e\u5b9a\u7fa9\r\n$ export RELEASE_NAME=cp600\r\n$ export KSQLDB=${RELEASE_NAME}-cp-ksql-server:8088\r\n\r\n## KsqlDB \u3078\u306e\u63a5\u7d9a\r\n$ ksql http:\/\/$KSQLDB\r\n\r\n## topic \u306e\u78ba\u8a8d\r\nksql> list topics;\r\n\r\n Kafka Topic | Partitions | Partition Replicas \r\n-----------------------------------------------------------------\r\n cp600-cp-kafka-connect-config | 1 | 3 \r\n cp600-cp-kafka-connect-offset | 25 | 3 \r\n cp600-cp-kafka-connect-status | 5 | 3 \r\n topic_201 | 3 | 1 \r\n topic_202 | 3 | 1 \r\n-----------------------------------------------------------------\r\n\r\n## stream_201 \/ stream_202 \u306e\u4f5c\u6210\r\nksql> CREATE STREAM stream_201 (id BIGINT, time VARCHAR, proc VARCHAR, section VARCHAR, iot_num VARCHAR, iot_state VARCHAR, vol_1 DOUBLE, vol_2 DOUBLE) WITH (KAFKA_TOPIC = 'topic_201', VALUE_FORMAT='JSON'); \r\n\r\nksql> CREATE STREAM stream_202 WITH (KAFKA_TOPIC = 'topic_202', VALUE_FORMAT='JSON') AS SELECT s201.section as section, s201.time as zztime, s201.proc as proc, s201.iot_num as iot_num, s201.iot_state as iot_state, s201.vol_1 as vol_1, s201.vol_2 as vol_2 FROM stream_201 s201 WHERE section='E' OR section='C' OR section='W'; \r\n\r\n## stream \u306e\u78ba\u8a8d\r\nksql> show streams;\r\n\r\n Stream Name | Kafka Topic | Format \r\n------------------------------------\r\n STREAM_201 | topic_201 | JSON \r\n STREAM_202 | topic_202 | JSON \r\n------------------------------------\r\n<\/code><\/pre>\n
\n\u8fde\u7ebf\u5668\u7684\u8bbe\u7f6e<\/h3>\n
\u4f7f\u7528\u4e86ACR\u7684\u5bb9\u5668\u6620\u50cf\uff0c\u6240\u4ee5\u9700\u8981\u786e\u8ba4\u662f\u5426\u5df2\u5b89\u88c5\u4e86RabbitMQ\/InfluxDB\u7684\u8fde\u63a5\u5668\u63d2\u4ef6\u3002<\/p>\n
$ kubectl port-forward --address localhost --namespace akscp01 svc\/cp600-cp-kafka-connect 8083:8083\r\nForwarding from 127.0.0.1:8083 -> 8083\r\nForwarding from [::1]:8083 -> 8083\r\n\r\n\u203b CTRL+C \u3067\u7d42\u4e86\u3067\u304d\u307e\u3059\r\n<\/code><\/pre>\n\u6253\u5f00\u53e6\u4e00\u4e2a\u7ec8\u7aef\u7a97\u53e3\uff0c\u786e\u8ba4RabbitMQSourceConnector\u548cInfluxDBSinkConnector\u7684\u63d2\u4ef6\u5df2\u7ecf\u5b58\u5728\u3002<\/p>\n
$ curl http:\/\/localhost:8083\/connector-plugins | jq \r\n\r\n % Total % Received % Xferd Average Speed Time Time Time Current\r\n Dload Upload Total Spent Left Speed\r\n100 793 100 793 0 0 6007 0 --:--:-- --:--:-- --:--:-- 5962\r\n[\r\n {\r\n \"class\": \"io.confluent.connect.rabbitmq.RabbitMQSourceConnector\",\r\n \"type\": \"source\",\r\n \"version\": \"0.0.0.0\"\r\n },\r\n {\r\n \"class\": \"io.confluent.influxdb.InfluxDBSinkConnector\",\r\n \"type\": \"sink\",\r\n \"version\": \"unknown\"\r\n },\r\n \uff1a\r\n \u4e2d\u7565\r\n \uff1a\r\n]\r\n<\/code><\/pre>\n\u521b\u5efaRabbitMQSourceConnector<\/h4>\n
RabbitMQSourceConnector \u7684\u5b9a\u4e49\u6587\u4ef6\u5982\u4e0b\u6240\u793a\u3002<\/p>\n
{<\/span>\r\n \"name\"<\/span> :<\/span> \"RabbitMQSourceConnector_1\"<\/span>,<\/span>\r\n \"config\"<\/span> :<\/span> {<\/span>\r\n \"connector.class\"<\/span> :<\/span> \"io.confluent.connect.rabbitmq.RabbitMQSourceConnector\"<\/span>,<\/span>\r\n \"tasks.max\"<\/span> :<\/span> \"1\"<\/span>,<\/span>\r\n \"value.converter\"<\/span>:<\/span> \"org.apache.kafka.connect.converters.ByteArrayConverter\"<\/span>,<\/span>\r\n \"rabbitmq.host\"<\/span>:<\/span> \"cp600mq-rabbitmq\"<\/span>,<\/span>\r\n \"rabbitmq.username\"<\/span>:<\/span> \"guest\"<\/span>,<\/span>\r\n \"rabbitmq.password\"<\/span>:<\/span> \"guest\"<\/span>,<\/span>\r\n \"rabbitmq.port\"<\/span>:<\/span> \"5672\"<\/span>,<\/span>\r\n \"kafka.topic\"<\/span>:<\/span> \"topic_201\"<\/span>,<\/span>\r\n \"rabbitmq.queue\"<\/span>:<\/span> \"IoTHub\"<\/span>\r\n }<\/span>\r\n}<\/span>\r\n<\/code><\/pre>\n\u521b\u5efa\u4e00\u4e2a\u65b0\u7684RabbitMQSourceConnector<\/p>\n
$ curl -s -X POST -H 'Content-Type: application\/json' --data @RabbitMQSourceConnector.json http:\/\/localhost:8083\/connectors\r\n\r\n{\"name\":\"RabbitMQSourceConnector_1\",\"config\":{\"connector.class\":\"io.confluent.connect.rabbitmq.RabbitMQSourceConnector\",\"tasks.max\":\"1\",\"value.converter\":\"org.apache.kafka.connect.converters.ByteArrayConverter\",\"rabbitmq.host\":\"cp600mq-rabbitmq\",\"rabbitmq.username\":\"guest\",\"rabbitmq.password\":\"guest\",\"rabbitmq.port\":\"5672\",\"kafka.topic\":\"topic_201\",\"rabbitmq.queue\":\"IoTHub\",\"name\":\"RabbitMQSourceConnector_1\"},\"tasks\":[],\"type\":\"source\"}\r\n<\/code><\/pre>\n\u521b\u5efa InfluxDBSinkConnector<\/h4>\n
InfluxDBSinkConnector\u7684\u5b9a\u4e49\u6587\u4ef6\u5982\u4e0b\u6240\u793a\u3002<\/p>\n
{<\/span>\r\n \"name\"<\/span>:<\/span> \"InfluxDBSinkConnector_1\"<\/span>,<\/span>\r\n \"config\"<\/span> :<\/span> {<\/span>\r\n \"value.converter.schemas.enable\"<\/span>:<\/span> \"false\"<\/span>,<\/span>\r\n \"connector.class\"<\/span>:<\/span> \"io.confluent.influxdb.InfluxDBSinkConnector\"<\/span>,<\/span>\r\n \"tasks.max\"<\/span>:<\/span> \"1\"<\/span>,<\/span>\r\n \"value.converter\"<\/span>:<\/span> \"org.apache.kafka.connect.json.JsonConverter\"<\/span>,<\/span>\r\n \"topics\"<\/span>:<\/span> \"topic_201, topic_202\"<\/span>,<\/span>\r\n \"influxdb.url\"<\/span>:<\/span> \"http:\/\/cp600db-influxdb:8086\"<\/span>,<\/span>\r\n \"influxdb.db\"<\/span>:<\/span> \"IoTSample\"<\/span>,<\/span>\r\n \"measurement.name.format\"<\/span>:<\/span> \"${topic}\"<\/span>\r\n }<\/span>\r\n}<\/span>\r\n<\/code><\/pre>\n\u521b\u5efa\u4e00\u4e2a\u65b0\u7684InfluxDBSinkConnector<\/p>\n
$ curl -s -X POST -H 'Content-Type: application\/json' --data @InfluxDBSinkConnector.json http:\/\/localhost:8083\/connectors\r\n\r\n{\"name\":\"InfluxDBSinkConnector_1\",\"config\":{\"value.converter.schemas.enable\":\"false\",\"connector.class\":\"io.confluent.influxdb.InfluxDBSinkConnector\",\"tasks.max\":\"1\",\"value.converter\":\"org.apache.kafka.connect.json.JsonConverter\",\"topics\":\"topic_201, topic_202\",\"influxdb.url\":\"http:\/\/influxdb:8086\",\"influxdb.db\":\"IoTSample\",\"measurement.name.format\":\"${topic}\",\"name\":\"InfluxDBSinkConnector_1\"},\"tasks\":[],\"type\":\"sink\"}\r\n<\/code><\/pre>\n\u8fde\u63a5\u5668\u7684\u786e\u8ba4<\/h4>\n$ curl -s \"http:\/\/localhost:8083\/connectors?expand=info&expand=status\" | \\\r\n jq '. | to_entries[] | [ .value.info.type, .key, .value.status.connector.state,.value.status.tasks[].state,.value.info.config.\"connector.class\"]|join(\":|:\")' | \\\r\n column -s : -t| sed 's\/\\\"\/\/g'| sort\r\n\r\nsink | InfluxDBSinkConnector_1 | RUNNING | RUNNING | io.confluent.influxdb.InfluxDBSinkConnector\r\nsource | RabbitMQSourceConnector_1 | RUNNING | RUNNING | io.confluent.connect.rabbitmq.RabbitMQSourceConnector\r\n<\/code><\/pre>\n
\nInfluxDB\u7684\u914d\u7f6e<\/h3>\n## influxdb \u3078\u306e\u63a5\u7d9a\r\n$ kubectl exec -it svc\/cp600db-influxdb -n akscp01 -- influx \r\n\r\nConnected to http:\/\/localhost:8086 version 1.8.5\r\nInfluxDB shell version: 1.8.5\r\n>\r\n\r\n## \u30c7\u30fc\u30bf\u30d9\u30fc\u30b9\u300cIoTSample\u300d\u306e\u4f5c\u6210\u3068\u78ba\u8a8d\r\n> create database IoTSample\r\n> show databases\r\nname: databases\r\nname\r\n----\r\n_internal\r\nIoTSample\r\n<\/code><\/pre>\n
\nGrafana\u7684\u8bbe\u7f6e<\/h3>\n
\u4e3a\u4e86\u901a\u8fc7GUI\u8fdb\u884cGrafana\u8bbe\u7f6e\uff0c\u6211\u4eec\u9700\u8981\u8fdb\u884cGrafana GUI\u7684\u7aef\u53e3\u8f6c\u53d1\u914d\u7f6e\u3002<\/p>\n
$ kubectl port-forward --address localhost --namespace akscp01 svc\/cp600gf-grafana 3000:3000\r\nForwarding from 127.0.0.1:3000 -> 3000\r\nForwarding from [::1]:3000 -> 3000\r\n\r\n\u203b CTRL+C \u3067\u7d42\u4e86\u3067\u304d\u307e\u3059\r\n<\/code><\/pre>\n\u5c06\u5728\u8fd9\u7bc7\u6587\u7ae0\u4e2d\u8fdb\u884c”\u8fde\u63a5Grafana\u548cInfluxDB\u7684\u8bbe\u7f6e”\u548c”\u521b\u5efaGrafana\u4eea\u8868\u677f”\u7684\u914d\u7f6e\u3002
\n\u4f46\u662f\uff0c\u8bf7\u5c06URL\u8bbe\u7f6e\u503c\u4ecehttp:\/\/influxdb:8086\u66f4\u6539\u4e3ahttp:\/\/cp600db-influxdb:8086\u3002<\/p>\n
RabbitMQ\u7684\u914d\u7f6e<\/h3>\n
\u7531\u4e8e\u4f7f\u7528\u4e86ACR\u7684\u5bb9\u5668\u6620\u50cf\uff0c\u6240\u4ee5\u6ca1\u6709\u4efb\u4f55\u914d\u7f6e\u4f4d\u7f6e\u3002<\/p>\n
\n\u5e94\u7528\u7a0b\u5e8f\u7684\u8fd0\u884c\u786e\u8ba4<\/h2>\n\u8bbe\u7f6e\u7aef\u53e3\u8f6c\u53d1<\/h3>\n
\u7531\u4e8e\u5bb9\u5668\u5e94\u7528\u7a0b\u5e8f\u4e0d\u8fdb\u884c\u5916\u90e8\u516c\u5f00\uff0c\u6240\u4ee5\u9700\u8981\u5bf9\u5145\u5f53\u5916\u90e8\u63a5\u53e3\u7684\u5bb9\u5668\u5e94\u7528\u7a0b\u5e8f rabbitmq \u548c grafana \u8fdb\u884c\u7aef\u53e3\u8f6c\u53d1\u7684\u8bbe\u7f6e\u3002<\/p>\n
$ kubectl port-forward --address localhost --namespace akscp01 svc\/cp600gf-grafana 3000:3000 &\r\n$ kubectl port-forward --address localhost --namespace akscp01 svc\/cp600mq-rabbitmq 5672:5672 &\r\n<\/code><\/pre>\n\u5e94\u7528\u7a0b\u5e8f\u7684\u8fd0\u884c<\/h3>\n
\u4e0e”\u5b9e\u65f6\u53ef\u89c6\u5316\u901a\u8fc7Grafana\u4eea\u8868\u76d8”\u4e2d\u63d0\u5230\u7684\u76f8\u540c\uff0c\u6211\u4eec\u53ef\u4ee5\u901a\u8fc7\u672c\u5730\u7ec8\u7aef\u6267\u884cIoT\u6570\u636e\u751f\u6210\u7a0b\u5e8f\u3002\u6211\u4eec\u751f\u6210\u4e86100\u6761\u6570\u636e\uff0c\u6bcf\u79d2\u751f\u6210\u4e00\u6761\u3002<\/p>\n
$ python IoTSampleData-v5.py --mode mq --count 100 --wait 1\r\n<\/code><\/pre>\n![\"image.png\"](\"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d7b0c913a08637a697f46\/54-0.png\" "\\"\\"")
<\/div>\n
\n\u6574\u7406\u4e8b\u540e\u7684\u5de5\u4f5c<\/h2>\n\u505c\u6b62\u7aef\u53e3\u8f6c\u53d1<\/h3>\n## \u8a72\u5f53\u306e\u30d7\u30ed\u30bb\u30b9\u3092\u691c\u7d22\u3057\u307e\u3059\r\n$ ps -axl | grep kubectl \r\n 501 35260 8527 4006 0 31 5 5052880 34332 - SN 0 ttys000 0:00.23 kubectl port-forward --address localhost --namespace akscp01 svc\/cp600gf-grafana 3000:3000\r\n 501 35261 8527 4006 0 31 5 5053160 33008 - SN 0 ttys000 0:00.20 kubectl port-forward --address localhost --namespace akscp01 svc\/cp600mq-rabbitmq 5672:5672\r\n 501 35276 18433 4006 0 31 0 4399480 828 - S+ 0 ttys002 0:00.00 grep kubectl\r\n\r\n## \u8a72\u5f53\u306e\u30d7\u30ed\u30bb\u30b9\u3092 kill \u3057\u307e\u3059\r\n$ kill 35260 \r\n$ kill 35261\r\n<\/code><\/pre>\n\u5378\u8f7dPod<\/h3>\n$ helm delete cp600gf -n akscp01\r\n$ helm delete cp600db -n akscp01\r\n$ helm delete cp600mq -n akscp01\r\n$ helm delete cp600 -n akscp01\r\n<\/code><\/pre>\n\u5220\u9664\u547d\u540d\u7a7a\u95f4<\/h3>\n$ kubectl delete namespace akscp01\r\n<\/code><\/pre>\n
\n\u603b\u7ed3<\/h2>\n
\u6211\u4ee5\u76f8\u5f53\u571f\u6c14\u7684\u65b9\u5f0f\u5f3a\u884c\u5b9e\u73b0\u4e86\u5bb9\u5668\u5e94\u7528\u7a0b\u5e8f\uff0c\u4f46\u6211\u5e0c\u671b\u82b1\u70b9\u65f6\u95f4\uff0c\u5229\u7528 ConfigMap \u548c\u5404\u79cd\u914d\u7f6e\u6587\u4ef6\u52a0\u8f7d\u7b49\u65b9\u6cd5\uff0c\u8ffd\u6c42\u65f6\u5c1a\u7684\u5b9e\u73b0\u65b9\u5f0f\u3002<\/p>\n
\n\u672c\u8bfe\u9898\u7684\u6b65\u9aa4\u4fe1\u606f<\/h3>\n
\u7b2c\u4e00\u6b65\uff1a\u5728AKS\u4e0a\u6784\u5efaConfluent\u5e73\u53f0\u73af\u5883
\n\u7b2c\u4e8c\u6b65\uff1a\u5728AKS\u4e0a\u8fd0\u884c\u5bb9\u5668\u5e94\u7528\u7a0b\u5e8f<\/p>\n
\u53c2\u8003\u8d44\u6599<\/h3>\n
\u611f\u8c22\u60a8\u63d0\u4f9b\u7684\u4ee5\u4e0b\u4fe1\u606f\u3002\u6211\u5c06\u53c2\u8003\u5b83\u4eec\u3002\u63a8\u8350\u4f7f\u7528Helm v3\u3002
\nHelm\u662f\u7528\u4e8eKubernetes\u7684\u4e8b\u5b9e\u4e0a\u7684\u6807\u51c6\u90e8\u7f72\u5de5\u5177\u3002<\/p>\n","protected":false},"excerpt":{"rendered":"
\u6982\u8981 – \u7b80\u8981\u7248\u7684\u63cf\u8ff0 \u6211\u53c2\u8003\u4e86\u8fd9\u7bc7\u6587\u7ae0\uff0c\u7528\u4e00\u70b9\u70b9\u7406\u89e3\u7684 Helm v3\uff0c\u603b\u7ed3\u4e86\u4f7f\u7528 Confue […]<\/p>\n","protected":false},"author":9,"featured_media":0,"comment_status":"closed","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[],"class_list":["post-46806","post","type-post","status-publish","format-standard","hentry","category-uncategorized"],"yoast_head":"\n
\u6211\u5c1d\u8bd5\u4f7f\u7528Azure Kubernetes Service (AKS)\u548cConfluent Platform\u7684Helm Chart\u6765\u8fd0\u884c\u5e94\u7528\u7a0b\u5e8f - Blog - Silicon Cloud<\/title>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"https:\/\/www.silicloud.com\/zh\/blog\/\u6211\u5c1d\u8bd5\u4f7f\u7528azure-kubernetes-service-aks\u548cconfluent-platform\u7684helm-chart\u6765\u8fd0\u884c\u5e94\u7528\u7a0b\u5e8f\u3002\/\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"\u6211\u5c1d\u8bd5\u4f7f\u7528Azure Kubernetes Service (AKS)\u548cConfluent Platform\u7684Helm Chart\u6765\u8fd0\u884c\u5e94\u7528\u7a0b\u5e8f\" \/>\n<meta property=\"og:description\" content=\"\u6982\u8981 – \u7b80\u8981\u7248\u7684\u63cf\u8ff0 \u6211\u53c2\u8003\u4e86\u8fd9\u7bc7\u6587\u7ae0\uff0c\u7528\u4e00\u70b9\u70b9\u7406\u89e3\u7684 Helm v3\uff0c\u603b\u7ed3\u4e86\u4f7f\u7528 Confue […]\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.silicloud.com\/zh\/blog\/\u6211\u5c1d\u8bd5\u4f7f\u7528azure-kubernetes-service-aks\u548cconfluent-platform\u7684helm-chart\u6765\u8fd0\u884c\u5e94\u7528\u7a0b\u5e8f\u3002\/\" \/>\n<meta property=\"og:site_name\" content=\"Blog - Silicon Cloud\" \/>\n<meta property=\"article:published_time\" content=\"2022-11-22T14:00:20+00:00\" \/>\n<meta property=\"article:modified_time\" content=\"2024-04-29T01:47:04+00:00\" \/>\n<meta property=\"og:image\" content=\"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d7b0c913a08637a697f46\/2-0.png\" \/>\n<meta name=\"author\" content=\"\u6e05, \u626c\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"\u4f5c\u8005\" \/>\n\t<meta name=\"twitter:data1\" content=\"\u6e05, \u626c\" \/>\n\t<meta name=\"twitter:label2\" content=\"\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4\" \/>\n\t<meta name=\"twitter:data2\" content=\"4 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e6%88%91%e5%b0%9d%e8%af%95%e4%bd%bf%e7%94%a8azure-kubernetes-service-aks%e5%92%8cconfluent-platform%e7%9a%84helm-chart%e6%9d%a5%e8%bf%90%e8%a1%8c%e5%ba%94%e7%94%a8%e7%a8%8b%e5%ba%8f%e3%80%82\/\",\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e6%88%91%e5%b0%9d%e8%af%95%e4%bd%bf%e7%94%a8azure-kubernetes-service-aks%e5%92%8cconfluent-platform%e7%9a%84helm-chart%e6%9d%a5%e8%bf%90%e8%a1%8c%e5%ba%94%e7%94%a8%e7%a8%8b%e5%ba%8f%e3%80%82\/\",\"name\":\"\u6211\u5c1d\u8bd5\u4f7f\u7528Azure Kubernetes Service (AKS)\u548cConfluent Platform\u7684Helm Chart\u6765\u8fd0\u884c\u5e94\u7528\u7a0b\u5e8f - Blog - Silicon Cloud\",\"isPartOf\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#website\"},\"datePublished\":\"2022-11-22T14:00:20+00:00\",\"dateModified\":\"2024-04-29T01:47:04+00:00\",\"author\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/cb5556d2501da73d864cac945e8d9461\"},\"breadcrumb\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e6%88%91%e5%b0%9d%e8%af%95%e4%bd%bf%e7%94%a8azure-kubernetes-service-aks%e5%92%8cconfluent-platform%e7%9a%84helm-chart%e6%9d%a5%e8%bf%90%e8%a1%8c%e5%ba%94%e7%94%a8%e7%a8%8b%e5%ba%8f%e3%80%82\/#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.silicloud.com\/zh\/blog\/%e6%88%91%e5%b0%9d%e8%af%95%e4%bd%bf%e7%94%a8azure-kubernetes-service-aks%e5%92%8cconfluent-platform%e7%9a%84helm-chart%e6%9d%a5%e8%bf%90%e8%a1%8c%e5%ba%94%e7%94%a8%e7%a8%8b%e5%ba%8f%e3%80%82\/\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e6%88%91%e5%b0%9d%e8%af%95%e4%bd%bf%e7%94%a8azure-kubernetes-service-aks%e5%92%8cconfluent-platform%e7%9a%84helm-chart%e6%9d%a5%e8%bf%90%e8%a1%8c%e5%ba%94%e7%94%a8%e7%a8%8b%e5%ba%8f%e3%80%82\/#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/www.silicloud.com\/zh\/blog\/\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"\u6211\u5c1d\u8bd5\u4f7f\u7528Azure Kubernetes Service (AKS)\u548cConfluent Platform\u7684Helm Chart\u6765\u8fd0\u884c\u5e94\u7528\u7a0b\u5e8f\"}]},{\"@type\":\"WebSite\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#website\",\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/\",\"name\":\"Blog - Silicon Cloud\",\"description\":\"\",\"inLanguage\":\"zh-Hans\"},{\"@type\":\"Person\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/cb5556d2501da73d864cac945e8d9461\",\"name\":\"\u6e05, \u626c\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/secure.gravatar.com\/avatar\/32a4239de8ff29adace466261d309424a1e5fe9f7e3036bf89fe03f2e3dbe717?s=96&d=mm&r=g\",\"contentUrl\":\"https:\/\/secure.gravatar.com\/avatar\/32a4239de8ff29adace466261d309424a1e5fe9f7e3036bf89fe03f2e3dbe717?s=96&d=mm&r=g\",\"caption\":\"\u6e05, \u626c\"},\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/author\/qingyang\/\"},{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e6%88%91%e5%b0%9d%e8%af%95%e4%bd%bf%e7%94%a8azure-kubernetes-service-aks%e5%92%8cconfluent-platform%e7%9a%84helm-chart%e6%9d%a5%e8%bf%90%e8%a1%8c%e5%ba%94%e7%94%a8%e7%a8%8b%e5%ba%8f%e3%80%82\/#local-main-organization-logo\",\"url\":\"\",\"contentUrl\":\"\",\"caption\":\"Blog - Silicon Cloud\"}]}<\/script>\n<!-- \/ Yoast SEO Premium plugin. -->","yoast_head_json":{"title":"\u6211\u5c1d\u8bd5\u4f7f\u7528Azure Kubernetes Service (AKS)\u548cConfluent Platform\u7684Helm Chart\u6765\u8fd0\u884c\u5e94\u7528\u7a0b\u5e8f - Blog - Silicon Cloud","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"https:\/\/www.silicloud.com\/zh\/blog\/\u6211\u5c1d\u8bd5\u4f7f\u7528azure-kubernetes-service-aks\u548cconfluent-platform\u7684helm-chart\u6765\u8fd0\u884c\u5e94\u7528\u7a0b\u5e8f\u3002\/","og_locale":"zh_CN","og_type":"article","og_title":"\u6211\u5c1d\u8bd5\u4f7f\u7528Azure Kubernetes Service (AKS)\u548cConfluent Platform\u7684Helm Chart\u6765\u8fd0\u884c\u5e94\u7528\u7a0b\u5e8f","og_description":"\u6982\u8981 – \u7b80\u8981\u7248\u7684\u63cf\u8ff0 \u6211\u53c2\u8003\u4e86\u8fd9\u7bc7\u6587\u7ae0\uff0c\u7528\u4e00\u70b9\u70b9\u7406\u89e3\u7684 Helm v3\uff0c\u603b\u7ed3\u4e86\u4f7f\u7528 Confue […]","og_url":"https:\/\/www.silicloud.com\/zh\/blog\/\u6211\u5c1d\u8bd5\u4f7f\u7528azure-kubernetes-service-aks\u548cconfluent-platform\u7684helm-chart\u6765\u8fd0\u884c\u5e94\u7528\u7a0b\u5e8f\u3002\/","og_site_name":"Blog - Silicon Cloud","article_published_time":"2022-11-22T14:00:20+00:00","article_modified_time":"2024-04-29T01:47:04+00:00","og_image":[{"url":"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d7b0c913a08637a697f46\/2-0.png"}],"author":"\u6e05, \u626c","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"\u6e05, \u626c","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"4 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e6%88%91%e5%b0%9d%e8%af%95%e4%bd%bf%e7%94%a8azure-kubernetes-service-aks%e5%92%8cconfluent-platform%e7%9a%84helm-chart%e6%9d%a5%e8%bf%90%e8%a1%8c%e5%ba%94%e7%94%a8%e7%a8%8b%e5%ba%8f%e3%80%82\/","url":"https:\/\/www.silicloud.com\/zh\/blog\/%e6%88%91%e5%b0%9d%e8%af%95%e4%bd%bf%e7%94%a8azure-kubernetes-service-aks%e5%92%8cconfluent-platform%e7%9a%84helm-chart%e6%9d%a5%e8%bf%90%e8%a1%8c%e5%ba%94%e7%94%a8%e7%a8%8b%e5%ba%8f%e3%80%82\/","name":"\u6211\u5c1d\u8bd5\u4f7f\u7528Azure Kubernetes Service (AKS)\u548cConfluent Platform\u7684Helm Chart\u6765\u8fd0\u884c\u5e94\u7528\u7a0b\u5e8f - Blog - Silicon Cloud","isPartOf":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/#website"},"datePublished":"2022-11-22T14:00:20+00:00","dateModified":"2024-04-29T01:47:04+00:00","author":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/cb5556d2501da73d864cac945e8d9461"},"breadcrumb":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e6%88%91%e5%b0%9d%e8%af%95%e4%bd%bf%e7%94%a8azure-kubernetes-service-aks%e5%92%8cconfluent-platform%e7%9a%84helm-chart%e6%9d%a5%e8%bf%90%e8%a1%8c%e5%ba%94%e7%94%a8%e7%a8%8b%e5%ba%8f%e3%80%82\/#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.silicloud.com\/zh\/blog\/%e6%88%91%e5%b0%9d%e8%af%95%e4%bd%bf%e7%94%a8azure-kubernetes-service-aks%e5%92%8cconfluent-platform%e7%9a%84helm-chart%e6%9d%a5%e8%bf%90%e8%a1%8c%e5%ba%94%e7%94%a8%e7%a8%8b%e5%ba%8f%e3%80%82\/"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e6%88%91%e5%b0%9d%e8%af%95%e4%bd%bf%e7%94%a8azure-kubernetes-service-aks%e5%92%8cconfluent-platform%e7%9a%84helm-chart%e6%9d%a5%e8%bf%90%e8%a1%8c%e5%ba%94%e7%94%a8%e7%a8%8b%e5%ba%8f%e3%80%82\/#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/www.silicloud.com\/zh\/blog\/"},{"@type":"ListItem","position":2,"name":"\u6211\u5c1d\u8bd5\u4f7f\u7528Azure Kubernetes Service (AKS)\u548cConfluent Platform\u7684Helm Chart\u6765\u8fd0\u884c\u5e94\u7528\u7a0b\u5e8f"}]},{"@type":"WebSite","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#website","url":"https:\/\/www.silicloud.com\/zh\/blog\/","name":"Blog - Silicon Cloud","description":"","inLanguage":"zh-Hans"},{"@type":"Person","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/cb5556d2501da73d864cac945e8d9461","name":"\u6e05, \u626c","image":{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/image\/","url":"https:\/\/secure.gravatar.com\/avatar\/32a4239de8ff29adace466261d309424a1e5fe9f7e3036bf89fe03f2e3dbe717?s=96&d=mm&r=g","contentUrl":"https:\/\/secure.gravatar.com\/avatar\/32a4239de8ff29adace466261d309424a1e5fe9f7e3036bf89fe03f2e3dbe717?s=96&d=mm&r=g","caption":"\u6e05, \u626c"},"url":"https:\/\/www.silicloud.com\/zh\/blog\/author\/qingyang\/"},{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e6%88%91%e5%b0%9d%e8%af%95%e4%bd%bf%e7%94%a8azure-kubernetes-service-aks%e5%92%8cconfluent-platform%e7%9a%84helm-chart%e6%9d%a5%e8%bf%90%e8%a1%8c%e5%ba%94%e7%94%a8%e7%a8%8b%e5%ba%8f%e3%80%82\/#local-main-organization-logo","url":"","contentUrl":"","caption":"Blog - Silicon Cloud"}]}},"_links":{"self":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/46806","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/users\/9"}],"replies":[{"embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/comments?post=46806"}],"version-history":[{"count":2,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/46806\/revisions"}],"predecessor-version":[{"id":84532,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/46806\/revisions\/84532"}],"wp:attachment":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/media?parent=46806"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/categories?post=46806"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/tags?post=46806"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}
- \u53c2\u8003\u306b\u3057\u3066\u3001\u5df2\u7ecf\u642d\u5efa\u597d\u4e86AKS\u548cACR\uff0c\u5e76\u4e14\u5df2\u7ecf\u786e\u8ba4\u5728AKS\u96c6\u7fa4\u4e0a\u8fd0\u884c\u7684\u8282\u70b9\u3002<\/ol>\n<\/li>\n<\/ol>\n
\u53c2\u8003\u6b64\u6587\u7ae0\uff0c\u5c06\u5bb9\u5668\u955c\u50cf\u63a8\u9001\u5230ACR\u3002<\/p>\n
\u786e\u8ba4\u5728\u6b64\u6587\u7ae0\u4e2d\u5df2\u7ecf\u5b8c\u6210\u4e86\u201cHelm\u51c6\u5907\u201d\u3002<\/p>\n
\n
\u5c06\u8bbe\u5b9a\u4f20\u9001\u5230Pod<\/h2>\n\u786e\u8ba4Pod<\/h3>\n$ kubectl get pod -n akscp01\r\n\r\nNAME READY STATUS RESTARTS AGE\r\ncp600-cp-control-center-5b55c5676f-tn5w9 1\/1 Running 3 3m46s\r\ncp600-cp-kafka-0 2\/2 Running 1 3m46s\r\ncp600-cp-kafka-1 2\/2 Running 0 3m8s\r\ncp600-cp-kafka-2 2\/2 Running 0 2m46s\r\ncp600-cp-kafka-connect-764c9bd6cd-n84qw 2\/2 Running 3 3m46s\r\ncp600-cp-ksql-server-5948c75b8b-dnfcm 2\/2 Running 4 3m46s\r\ncp600-cp-schema-registry-5d79b8c57-r4r5p 2\/2 Running 3 3m46s\r\ncp600-cp-zookeeper-0 2\/2 Running 0 3m46s\r\ncp600-cp-zookeeper-1 2\/2 Running 0 3m8s\r\ncp600-cp-zookeeper-2 2\/2 Running 0 2m32s\r\ncp600db-influxdb-5ff9b5cfbc-zkvjb 1\/1 Running 0 33m\r\ncp600gf-grafana-59cff8f44b-rwlwx 1\/1 Running 0 13m\r\ncp600mq-rabbitmq-0 1\/1 Running 0 6m22s\r\n<\/code><\/pre>\n
\n\u521b\u5efa Kafka \u4e3b\u9898<\/h3>\n## Kafka-client \u3078\u306e\u63a5\u7d9a\r\n$ kubectl exec -it kafka-client -n akscp01 -- \/bin\/bash\r\n\r\n## \u74b0\u5883\u5909\u6570\u306e\u5b9a\u7fa9\r\n$ export RELEASE_NAME=cp600\r\n$ export ZOOKEEPERS=${RELEASE_NAME}-cp-zookeeper:2181\r\n\r\n## topic_201 \/ topic_202 \u306e\u4f5c\u6210\r\n$ kafka-topics --zookeeper $ZOOKEEPERS --create --topic topic_201 --partitions 3 --replication-factor 1\r\n$ kafka-topics --zookeeper $ZOOKEEPERS --create --topic topic_202 --partitions 3 --replication-factor 1\r\n\r\n## topic \u306e\u78ba\u8a8d\r\n$ kafka-topics --zookeeper $ZOOKEEPERS --list\r\n<\/code><\/pre>\n
\nKSQL \u7684\u914d\u7f6e<\/h3>\n## Ksql-client \u3078\u306e\u63a5\u7d9a\r\n$ kubectl exec -it ksql-client -n akscp01 -- \/bin\/bash\r\n\r\n## \u74b0\u5883\u5909\u6570\u306e\u5b9a\u7fa9\r\n$ export RELEASE_NAME=cp600\r\n$ export KSQLDB=${RELEASE_NAME}-cp-ksql-server:8088\r\n\r\n## KsqlDB \u3078\u306e\u63a5\u7d9a\r\n$ ksql http:\/\/$KSQLDB\r\n\r\n## topic \u306e\u78ba\u8a8d\r\nksql> list topics;\r\n\r\n Kafka Topic | Partitions | Partition Replicas \r\n-----------------------------------------------------------------\r\n cp600-cp-kafka-connect-config | 1 | 3 \r\n cp600-cp-kafka-connect-offset | 25 | 3 \r\n cp600-cp-kafka-connect-status | 5 | 3 \r\n topic_201 | 3 | 1 \r\n topic_202 | 3 | 1 \r\n-----------------------------------------------------------------\r\n\r\n## stream_201 \/ stream_202 \u306e\u4f5c\u6210\r\nksql> CREATE STREAM stream_201 (id BIGINT, time VARCHAR, proc VARCHAR, section VARCHAR, iot_num VARCHAR, iot_state VARCHAR, vol_1 DOUBLE, vol_2 DOUBLE) WITH (KAFKA_TOPIC = 'topic_201', VALUE_FORMAT='JSON'); \r\n\r\nksql> CREATE STREAM stream_202 WITH (KAFKA_TOPIC = 'topic_202', VALUE_FORMAT='JSON') AS SELECT s201.section as section, s201.time as zztime, s201.proc as proc, s201.iot_num as iot_num, s201.iot_state as iot_state, s201.vol_1 as vol_1, s201.vol_2 as vol_2 FROM stream_201 s201 WHERE section='E' OR section='C' OR section='W'; \r\n\r\n## stream \u306e\u78ba\u8a8d\r\nksql> show streams;\r\n\r\n Stream Name | Kafka Topic | Format \r\n------------------------------------\r\n STREAM_201 | topic_201 | JSON \r\n STREAM_202 | topic_202 | JSON \r\n------------------------------------\r\n<\/code><\/pre>\n
\n\u8fde\u7ebf\u5668\u7684\u8bbe\u7f6e<\/h3>\n
\u4f7f\u7528\u4e86ACR\u7684\u5bb9\u5668\u6620\u50cf\uff0c\u6240\u4ee5\u9700\u8981\u786e\u8ba4\u662f\u5426\u5df2\u5b89\u88c5\u4e86RabbitMQ\/InfluxDB\u7684\u8fde\u63a5\u5668\u63d2\u4ef6\u3002<\/p>\n
$ kubectl port-forward --address localhost --namespace akscp01 svc\/cp600-cp-kafka-connect 8083:8083\r\nForwarding from 127.0.0.1:8083 -> 8083\r\nForwarding from [::1]:8083 -> 8083\r\n\r\n\u203b CTRL+C \u3067\u7d42\u4e86\u3067\u304d\u307e\u3059\r\n<\/code><\/pre>\n\u6253\u5f00\u53e6\u4e00\u4e2a\u7ec8\u7aef\u7a97\u53e3\uff0c\u786e\u8ba4RabbitMQSourceConnector\u548cInfluxDBSinkConnector\u7684\u63d2\u4ef6\u5df2\u7ecf\u5b58\u5728\u3002<\/p>\n
$ curl http:\/\/localhost:8083\/connector-plugins | jq \r\n\r\n % Total % Received % Xferd Average Speed Time Time Time Current\r\n Dload Upload Total Spent Left Speed\r\n100 793 100 793 0 0 6007 0 --:--:-- --:--:-- --:--:-- 5962\r\n[\r\n {\r\n \"class\": \"io.confluent.connect.rabbitmq.RabbitMQSourceConnector\",\r\n \"type\": \"source\",\r\n \"version\": \"0.0.0.0\"\r\n },\r\n {\r\n \"class\": \"io.confluent.influxdb.InfluxDBSinkConnector\",\r\n \"type\": \"sink\",\r\n \"version\": \"unknown\"\r\n },\r\n \uff1a\r\n \u4e2d\u7565\r\n \uff1a\r\n]\r\n<\/code><\/pre>\n\u521b\u5efaRabbitMQSourceConnector<\/h4>\n
RabbitMQSourceConnector \u7684\u5b9a\u4e49\u6587\u4ef6\u5982\u4e0b\u6240\u793a\u3002<\/p>\n
{<\/span>\r\n \"name\"<\/span> :<\/span> \"RabbitMQSourceConnector_1\"<\/span>,<\/span>\r\n \"config\"<\/span> :<\/span> {<\/span>\r\n \"connector.class\"<\/span> :<\/span> \"io.confluent.connect.rabbitmq.RabbitMQSourceConnector\"<\/span>,<\/span>\r\n \"tasks.max\"<\/span> :<\/span> \"1\"<\/span>,<\/span>\r\n \"value.converter\"<\/span>:<\/span> \"org.apache.kafka.connect.converters.ByteArrayConverter\"<\/span>,<\/span>\r\n \"rabbitmq.host\"<\/span>:<\/span> \"cp600mq-rabbitmq\"<\/span>,<\/span>\r\n \"rabbitmq.username\"<\/span>:<\/span> \"guest\"<\/span>,<\/span>\r\n \"rabbitmq.password\"<\/span>:<\/span> \"guest\"<\/span>,<\/span>\r\n \"rabbitmq.port\"<\/span>:<\/span> \"5672\"<\/span>,<\/span>\r\n \"kafka.topic\"<\/span>:<\/span> \"topic_201\"<\/span>,<\/span>\r\n \"rabbitmq.queue\"<\/span>:<\/span> \"IoTHub\"<\/span>\r\n }<\/span>\r\n}<\/span>\r\n<\/code><\/pre>\n\u521b\u5efa\u4e00\u4e2a\u65b0\u7684RabbitMQSourceConnector<\/p>\n
$ curl -s -X POST -H 'Content-Type: application\/json' --data @RabbitMQSourceConnector.json http:\/\/localhost:8083\/connectors\r\n\r\n{\"name\":\"RabbitMQSourceConnector_1\",\"config\":{\"connector.class\":\"io.confluent.connect.rabbitmq.RabbitMQSourceConnector\",\"tasks.max\":\"1\",\"value.converter\":\"org.apache.kafka.connect.converters.ByteArrayConverter\",\"rabbitmq.host\":\"cp600mq-rabbitmq\",\"rabbitmq.username\":\"guest\",\"rabbitmq.password\":\"guest\",\"rabbitmq.port\":\"5672\",\"kafka.topic\":\"topic_201\",\"rabbitmq.queue\":\"IoTHub\",\"name\":\"RabbitMQSourceConnector_1\"},\"tasks\":[],\"type\":\"source\"}\r\n<\/code><\/pre>\n\u521b\u5efa InfluxDBSinkConnector<\/h4>\n
InfluxDBSinkConnector\u7684\u5b9a\u4e49\u6587\u4ef6\u5982\u4e0b\u6240\u793a\u3002<\/p>\n
{<\/span>\r\n \"name\"<\/span>:<\/span> \"InfluxDBSinkConnector_1\"<\/span>,<\/span>\r\n \"config\"<\/span> :<\/span> {<\/span>\r\n \"value.converter.schemas.enable\"<\/span>:<\/span> \"false\"<\/span>,<\/span>\r\n \"connector.class\"<\/span>:<\/span> \"io.confluent.influxdb.InfluxDBSinkConnector\"<\/span>,<\/span>\r\n \"tasks.max\"<\/span>:<\/span> \"1\"<\/span>,<\/span>\r\n \"value.converter\"<\/span>:<\/span> \"org.apache.kafka.connect.json.JsonConverter\"<\/span>,<\/span>\r\n \"topics\"<\/span>:<\/span> \"topic_201, topic_202\"<\/span>,<\/span>\r\n \"influxdb.url\"<\/span>:<\/span> \"http:\/\/cp600db-influxdb:8086\"<\/span>,<\/span>\r\n \"influxdb.db\"<\/span>:<\/span> \"IoTSample\"<\/span>,<\/span>\r\n \"measurement.name.format\"<\/span>:<\/span> \"${topic}\"<\/span>\r\n }<\/span>\r\n}<\/span>\r\n<\/code><\/pre>\n\u521b\u5efa\u4e00\u4e2a\u65b0\u7684InfluxDBSinkConnector<\/p>\n
$ curl -s -X POST -H 'Content-Type: application\/json' --data @InfluxDBSinkConnector.json http:\/\/localhost:8083\/connectors\r\n\r\n{\"name\":\"InfluxDBSinkConnector_1\",\"config\":{\"value.converter.schemas.enable\":\"false\",\"connector.class\":\"io.confluent.influxdb.InfluxDBSinkConnector\",\"tasks.max\":\"1\",\"value.converter\":\"org.apache.kafka.connect.json.JsonConverter\",\"topics\":\"topic_201, topic_202\",\"influxdb.url\":\"http:\/\/influxdb:8086\",\"influxdb.db\":\"IoTSample\",\"measurement.name.format\":\"${topic}\",\"name\":\"InfluxDBSinkConnector_1\"},\"tasks\":[],\"type\":\"sink\"}\r\n<\/code><\/pre>\n\u8fde\u63a5\u5668\u7684\u786e\u8ba4<\/h4>\n$ curl -s \"http:\/\/localhost:8083\/connectors?expand=info&expand=status\" | \\\r\n jq '. | to_entries[] | [ .value.info.type, .key, .value.status.connector.state,.value.status.tasks[].state,.value.info.config.\"connector.class\"]|join(\":|:\")' | \\\r\n column -s : -t| sed 's\/\\\"\/\/g'| sort\r\n\r\nsink | InfluxDBSinkConnector_1 | RUNNING | RUNNING | io.confluent.influxdb.InfluxDBSinkConnector\r\nsource | RabbitMQSourceConnector_1 | RUNNING | RUNNING | io.confluent.connect.rabbitmq.RabbitMQSourceConnector\r\n<\/code><\/pre>\n
\nInfluxDB\u7684\u914d\u7f6e<\/h3>\n## influxdb \u3078\u306e\u63a5\u7d9a\r\n$ kubectl exec -it svc\/cp600db-influxdb -n akscp01 -- influx \r\n\r\nConnected to http:\/\/localhost:8086 version 1.8.5\r\nInfluxDB shell version: 1.8.5\r\n>\r\n\r\n## \u30c7\u30fc\u30bf\u30d9\u30fc\u30b9\u300cIoTSample\u300d\u306e\u4f5c\u6210\u3068\u78ba\u8a8d\r\n> create database IoTSample\r\n> show databases\r\nname: databases\r\nname\r\n----\r\n_internal\r\nIoTSample\r\n<\/code><\/pre>\n
\nGrafana\u7684\u8bbe\u7f6e<\/h3>\n
\u4e3a\u4e86\u901a\u8fc7GUI\u8fdb\u884cGrafana\u8bbe\u7f6e\uff0c\u6211\u4eec\u9700\u8981\u8fdb\u884cGrafana GUI\u7684\u7aef\u53e3\u8f6c\u53d1\u914d\u7f6e\u3002<\/p>\n
$ kubectl port-forward --address localhost --namespace akscp01 svc\/cp600gf-grafana 3000:3000\r\nForwarding from 127.0.0.1:3000 -> 3000\r\nForwarding from [::1]:3000 -> 3000\r\n\r\n\u203b CTRL+C \u3067\u7d42\u4e86\u3067\u304d\u307e\u3059\r\n<\/code><\/pre>\n\u5c06\u5728\u8fd9\u7bc7\u6587\u7ae0\u4e2d\u8fdb\u884c”\u8fde\u63a5Grafana\u548cInfluxDB\u7684\u8bbe\u7f6e”\u548c”\u521b\u5efaGrafana\u4eea\u8868\u677f”\u7684\u914d\u7f6e\u3002
\n\u4f46\u662f\uff0c\u8bf7\u5c06URL\u8bbe\u7f6e\u503c\u4ecehttp:\/\/influxdb:8086\u66f4\u6539\u4e3ahttp:\/\/cp600db-influxdb:8086\u3002<\/p>\n
RabbitMQ\u7684\u914d\u7f6e<\/h3>\n
\u7531\u4e8e\u4f7f\u7528\u4e86ACR\u7684\u5bb9\u5668\u6620\u50cf\uff0c\u6240\u4ee5\u6ca1\u6709\u4efb\u4f55\u914d\u7f6e\u4f4d\u7f6e\u3002<\/p>\n
\n\u5e94\u7528\u7a0b\u5e8f\u7684\u8fd0\u884c\u786e\u8ba4<\/h2>\n\u8bbe\u7f6e\u7aef\u53e3\u8f6c\u53d1<\/h3>\n
\u7531\u4e8e\u5bb9\u5668\u5e94\u7528\u7a0b\u5e8f\u4e0d\u8fdb\u884c\u5916\u90e8\u516c\u5f00\uff0c\u6240\u4ee5\u9700\u8981\u5bf9\u5145\u5f53\u5916\u90e8\u63a5\u53e3\u7684\u5bb9\u5668\u5e94\u7528\u7a0b\u5e8f rabbitmq \u548c grafana \u8fdb\u884c\u7aef\u53e3\u8f6c\u53d1\u7684\u8bbe\u7f6e\u3002<\/p>\n
$ kubectl port-forward --address localhost --namespace akscp01 svc\/cp600gf-grafana 3000:3000 &\r\n$ kubectl port-forward --address localhost --namespace akscp01 svc\/cp600mq-rabbitmq 5672:5672 &\r\n<\/code><\/pre>\n\u5e94\u7528\u7a0b\u5e8f\u7684\u8fd0\u884c<\/h3>\n
\u4e0e”\u5b9e\u65f6\u53ef\u89c6\u5316\u901a\u8fc7Grafana\u4eea\u8868\u76d8”\u4e2d\u63d0\u5230\u7684\u76f8\u540c\uff0c\u6211\u4eec\u53ef\u4ee5\u901a\u8fc7\u672c\u5730\u7ec8\u7aef\u6267\u884cIoT\u6570\u636e\u751f\u6210\u7a0b\u5e8f\u3002\u6211\u4eec\u751f\u6210\u4e86100\u6761\u6570\u636e\uff0c\u6bcf\u79d2\u751f\u6210\u4e00\u6761\u3002<\/p>\n
$ python IoTSampleData-v5.py --mode mq --count 100 --wait 1\r\n<\/code><\/pre>\n<\/div>\n
\n\u6574\u7406\u4e8b\u540e\u7684\u5de5\u4f5c<\/h2>\n\u505c\u6b62\u7aef\u53e3\u8f6c\u53d1<\/h3>\n## \u8a72\u5f53\u306e\u30d7\u30ed\u30bb\u30b9\u3092\u691c\u7d22\u3057\u307e\u3059\r\n$ ps -axl | grep kubectl \r\n 501 35260 8527 4006 0 31 5 5052880 34332 - SN 0 ttys000 0:00.23 kubectl port-forward --address localhost --namespace akscp01 svc\/cp600gf-grafana 3000:3000\r\n 501 35261 8527 4006 0 31 5 5053160 33008 - SN 0 ttys000 0:00.20 kubectl port-forward --address localhost --namespace akscp01 svc\/cp600mq-rabbitmq 5672:5672\r\n 501 35276 18433 4006 0 31 0 4399480 828 - S+ 0 ttys002 0:00.00 grep kubectl\r\n\r\n## \u8a72\u5f53\u306e\u30d7\u30ed\u30bb\u30b9\u3092 kill \u3057\u307e\u3059\r\n$ kill 35260 \r\n$ kill 35261\r\n<\/code><\/pre>\n\u5378\u8f7dPod<\/h3>\n$ helm delete cp600gf -n akscp01\r\n$ helm delete cp600db -n akscp01\r\n$ helm delete cp600mq -n akscp01\r\n$ helm delete cp600 -n akscp01\r\n<\/code><\/pre>\n\u5220\u9664\u547d\u540d\u7a7a\u95f4<\/h3>\n$ kubectl delete namespace akscp01\r\n<\/code><\/pre>\n
\n\u603b\u7ed3<\/h2>\n
\u6211\u4ee5\u76f8\u5f53\u571f\u6c14\u7684\u65b9\u5f0f\u5f3a\u884c\u5b9e\u73b0\u4e86\u5bb9\u5668\u5e94\u7528\u7a0b\u5e8f\uff0c\u4f46\u6211\u5e0c\u671b\u82b1\u70b9\u65f6\u95f4\uff0c\u5229\u7528 ConfigMap \u548c\u5404\u79cd\u914d\u7f6e\u6587\u4ef6\u52a0\u8f7d\u7b49\u65b9\u6cd5\uff0c\u8ffd\u6c42\u65f6\u5c1a\u7684\u5b9e\u73b0\u65b9\u5f0f\u3002<\/p>\n
\n\u672c\u8bfe\u9898\u7684\u6b65\u9aa4\u4fe1\u606f<\/h3>\n
\u7b2c\u4e00\u6b65\uff1a\u5728AKS\u4e0a\u6784\u5efaConfluent\u5e73\u53f0\u73af\u5883
\n\u7b2c\u4e8c\u6b65\uff1a\u5728AKS\u4e0a\u8fd0\u884c\u5bb9\u5668\u5e94\u7528\u7a0b\u5e8f<\/p>\n
\u53c2\u8003\u8d44\u6599<\/h3>\n
\u611f\u8c22\u60a8\u63d0\u4f9b\u7684\u4ee5\u4e0b\u4fe1\u606f\u3002\u6211\u5c06\u53c2\u8003\u5b83\u4eec\u3002\u63a8\u8350\u4f7f\u7528Helm v3\u3002
\nHelm\u662f\u7528\u4e8eKubernetes\u7684\u4e8b\u5b9e\u4e0a\u7684\u6807\u51c6\u90e8\u7f72\u5de5\u5177\u3002<\/p>\n","protected":false},"excerpt":{"rendered":"
\u6982\u8981 – \u7b80\u8981\u7248\u7684\u63cf\u8ff0 \u6211\u53c2\u8003\u4e86\u8fd9\u7bc7\u6587\u7ae0\uff0c\u7528\u4e00\u70b9\u70b9\u7406\u89e3\u7684 Helm v3\uff0c\u603b\u7ed3\u4e86\u4f7f\u7528 Confue […]<\/p>\n","protected":false},"author":9,"featured_media":0,"comment_status":"closed","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[],"class_list":["post-46806","post","type-post","status-publish","format-standard","hentry","category-uncategorized"],"yoast_head":"\n
\u6211\u5c1d\u8bd5\u4f7f\u7528Azure Kubernetes Service (AKS)\u548cConfluent Platform\u7684Helm Chart\u6765\u8fd0\u884c\u5e94\u7528\u7a0b\u5e8f - Blog - Silicon Cloud<\/title>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"https:\/\/www.silicloud.com\/zh\/blog\/\u6211\u5c1d\u8bd5\u4f7f\u7528azure-kubernetes-service-aks\u548cconfluent-platform\u7684helm-chart\u6765\u8fd0\u884c\u5e94\u7528\u7a0b\u5e8f\u3002\/\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"\u6211\u5c1d\u8bd5\u4f7f\u7528Azure Kubernetes Service (AKS)\u548cConfluent Platform\u7684Helm Chart\u6765\u8fd0\u884c\u5e94\u7528\u7a0b\u5e8f\" \/>\n<meta property=\"og:description\" content=\"\u6982\u8981 – \u7b80\u8981\u7248\u7684\u63cf\u8ff0 \u6211\u53c2\u8003\u4e86\u8fd9\u7bc7\u6587\u7ae0\uff0c\u7528\u4e00\u70b9\u70b9\u7406\u89e3\u7684 Helm v3\uff0c\u603b\u7ed3\u4e86\u4f7f\u7528 Confue […]\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.silicloud.com\/zh\/blog\/\u6211\u5c1d\u8bd5\u4f7f\u7528azure-kubernetes-service-aks\u548cconfluent-platform\u7684helm-chart\u6765\u8fd0\u884c\u5e94\u7528\u7a0b\u5e8f\u3002\/\" \/>\n<meta property=\"og:site_name\" content=\"Blog - Silicon Cloud\" \/>\n<meta property=\"article:published_time\" content=\"2022-11-22T14:00:20+00:00\" \/>\n<meta property=\"article:modified_time\" content=\"2024-04-29T01:47:04+00:00\" \/>\n<meta property=\"og:image\" content=\"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d7b0c913a08637a697f46\/2-0.png\" \/>\n<meta name=\"author\" content=\"\u6e05, \u626c\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"\u4f5c\u8005\" \/>\n\t<meta name=\"twitter:data1\" content=\"\u6e05, \u626c\" \/>\n\t<meta name=\"twitter:label2\" content=\"\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4\" \/>\n\t<meta name=\"twitter:data2\" content=\"4 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e6%88%91%e5%b0%9d%e8%af%95%e4%bd%bf%e7%94%a8azure-kubernetes-service-aks%e5%92%8cconfluent-platform%e7%9a%84helm-chart%e6%9d%a5%e8%bf%90%e8%a1%8c%e5%ba%94%e7%94%a8%e7%a8%8b%e5%ba%8f%e3%80%82\/\",\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e6%88%91%e5%b0%9d%e8%af%95%e4%bd%bf%e7%94%a8azure-kubernetes-service-aks%e5%92%8cconfluent-platform%e7%9a%84helm-chart%e6%9d%a5%e8%bf%90%e8%a1%8c%e5%ba%94%e7%94%a8%e7%a8%8b%e5%ba%8f%e3%80%82\/\",\"name\":\"\u6211\u5c1d\u8bd5\u4f7f\u7528Azure Kubernetes Service (AKS)\u548cConfluent Platform\u7684Helm Chart\u6765\u8fd0\u884c\u5e94\u7528\u7a0b\u5e8f - Blog - Silicon Cloud\",\"isPartOf\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#website\"},\"datePublished\":\"2022-11-22T14:00:20+00:00\",\"dateModified\":\"2024-04-29T01:47:04+00:00\",\"author\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/cb5556d2501da73d864cac945e8d9461\"},\"breadcrumb\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e6%88%91%e5%b0%9d%e8%af%95%e4%bd%bf%e7%94%a8azure-kubernetes-service-aks%e5%92%8cconfluent-platform%e7%9a%84helm-chart%e6%9d%a5%e8%bf%90%e8%a1%8c%e5%ba%94%e7%94%a8%e7%a8%8b%e5%ba%8f%e3%80%82\/#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.silicloud.com\/zh\/blog\/%e6%88%91%e5%b0%9d%e8%af%95%e4%bd%bf%e7%94%a8azure-kubernetes-service-aks%e5%92%8cconfluent-platform%e7%9a%84helm-chart%e6%9d%a5%e8%bf%90%e8%a1%8c%e5%ba%94%e7%94%a8%e7%a8%8b%e5%ba%8f%e3%80%82\/\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e6%88%91%e5%b0%9d%e8%af%95%e4%bd%bf%e7%94%a8azure-kubernetes-service-aks%e5%92%8cconfluent-platform%e7%9a%84helm-chart%e6%9d%a5%e8%bf%90%e8%a1%8c%e5%ba%94%e7%94%a8%e7%a8%8b%e5%ba%8f%e3%80%82\/#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/www.silicloud.com\/zh\/blog\/\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"\u6211\u5c1d\u8bd5\u4f7f\u7528Azure Kubernetes Service (AKS)\u548cConfluent Platform\u7684Helm Chart\u6765\u8fd0\u884c\u5e94\u7528\u7a0b\u5e8f\"}]},{\"@type\":\"WebSite\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#website\",\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/\",\"name\":\"Blog - Silicon Cloud\",\"description\":\"\",\"inLanguage\":\"zh-Hans\"},{\"@type\":\"Person\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/cb5556d2501da73d864cac945e8d9461\",\"name\":\"\u6e05, \u626c\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/secure.gravatar.com\/avatar\/32a4239de8ff29adace466261d309424a1e5fe9f7e3036bf89fe03f2e3dbe717?s=96&d=mm&r=g\",\"contentUrl\":\"https:\/\/secure.gravatar.com\/avatar\/32a4239de8ff29adace466261d309424a1e5fe9f7e3036bf89fe03f2e3dbe717?s=96&d=mm&r=g\",\"caption\":\"\u6e05, \u626c\"},\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/author\/qingyang\/\"},{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e6%88%91%e5%b0%9d%e8%af%95%e4%bd%bf%e7%94%a8azure-kubernetes-service-aks%e5%92%8cconfluent-platform%e7%9a%84helm-chart%e6%9d%a5%e8%bf%90%e8%a1%8c%e5%ba%94%e7%94%a8%e7%a8%8b%e5%ba%8f%e3%80%82\/#local-main-organization-logo\",\"url\":\"\",\"contentUrl\":\"\",\"caption\":\"Blog - Silicon Cloud\"}]}<\/script>\n<!-- \/ Yoast SEO Premium plugin. -->","yoast_head_json":{"title":"\u6211\u5c1d\u8bd5\u4f7f\u7528Azure Kubernetes Service (AKS)\u548cConfluent Platform\u7684Helm Chart\u6765\u8fd0\u884c\u5e94\u7528\u7a0b\u5e8f - Blog - Silicon Cloud","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"https:\/\/www.silicloud.com\/zh\/blog\/\u6211\u5c1d\u8bd5\u4f7f\u7528azure-kubernetes-service-aks\u548cconfluent-platform\u7684helm-chart\u6765\u8fd0\u884c\u5e94\u7528\u7a0b\u5e8f\u3002\/","og_locale":"zh_CN","og_type":"article","og_title":"\u6211\u5c1d\u8bd5\u4f7f\u7528Azure Kubernetes Service (AKS)\u548cConfluent Platform\u7684Helm Chart\u6765\u8fd0\u884c\u5e94\u7528\u7a0b\u5e8f","og_description":"\u6982\u8981 – \u7b80\u8981\u7248\u7684\u63cf\u8ff0 \u6211\u53c2\u8003\u4e86\u8fd9\u7bc7\u6587\u7ae0\uff0c\u7528\u4e00\u70b9\u70b9\u7406\u89e3\u7684 Helm v3\uff0c\u603b\u7ed3\u4e86\u4f7f\u7528 Confue […]","og_url":"https:\/\/www.silicloud.com\/zh\/blog\/\u6211\u5c1d\u8bd5\u4f7f\u7528azure-kubernetes-service-aks\u548cconfluent-platform\u7684helm-chart\u6765\u8fd0\u884c\u5e94\u7528\u7a0b\u5e8f\u3002\/","og_site_name":"Blog - Silicon Cloud","article_published_time":"2022-11-22T14:00:20+00:00","article_modified_time":"2024-04-29T01:47:04+00:00","og_image":[{"url":"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d7b0c913a08637a697f46\/2-0.png"}],"author":"\u6e05, \u626c","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"\u6e05, \u626c","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"4 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e6%88%91%e5%b0%9d%e8%af%95%e4%bd%bf%e7%94%a8azure-kubernetes-service-aks%e5%92%8cconfluent-platform%e7%9a%84helm-chart%e6%9d%a5%e8%bf%90%e8%a1%8c%e5%ba%94%e7%94%a8%e7%a8%8b%e5%ba%8f%e3%80%82\/","url":"https:\/\/www.silicloud.com\/zh\/blog\/%e6%88%91%e5%b0%9d%e8%af%95%e4%bd%bf%e7%94%a8azure-kubernetes-service-aks%e5%92%8cconfluent-platform%e7%9a%84helm-chart%e6%9d%a5%e8%bf%90%e8%a1%8c%e5%ba%94%e7%94%a8%e7%a8%8b%e5%ba%8f%e3%80%82\/","name":"\u6211\u5c1d\u8bd5\u4f7f\u7528Azure Kubernetes Service (AKS)\u548cConfluent Platform\u7684Helm Chart\u6765\u8fd0\u884c\u5e94\u7528\u7a0b\u5e8f - Blog - Silicon Cloud","isPartOf":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/#website"},"datePublished":"2022-11-22T14:00:20+00:00","dateModified":"2024-04-29T01:47:04+00:00","author":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/cb5556d2501da73d864cac945e8d9461"},"breadcrumb":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e6%88%91%e5%b0%9d%e8%af%95%e4%bd%bf%e7%94%a8azure-kubernetes-service-aks%e5%92%8cconfluent-platform%e7%9a%84helm-chart%e6%9d%a5%e8%bf%90%e8%a1%8c%e5%ba%94%e7%94%a8%e7%a8%8b%e5%ba%8f%e3%80%82\/#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.silicloud.com\/zh\/blog\/%e6%88%91%e5%b0%9d%e8%af%95%e4%bd%bf%e7%94%a8azure-kubernetes-service-aks%e5%92%8cconfluent-platform%e7%9a%84helm-chart%e6%9d%a5%e8%bf%90%e8%a1%8c%e5%ba%94%e7%94%a8%e7%a8%8b%e5%ba%8f%e3%80%82\/"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e6%88%91%e5%b0%9d%e8%af%95%e4%bd%bf%e7%94%a8azure-kubernetes-service-aks%e5%92%8cconfluent-platform%e7%9a%84helm-chart%e6%9d%a5%e8%bf%90%e8%a1%8c%e5%ba%94%e7%94%a8%e7%a8%8b%e5%ba%8f%e3%80%82\/#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/www.silicloud.com\/zh\/blog\/"},{"@type":"ListItem","position":2,"name":"\u6211\u5c1d\u8bd5\u4f7f\u7528Azure Kubernetes Service (AKS)\u548cConfluent Platform\u7684Helm Chart\u6765\u8fd0\u884c\u5e94\u7528\u7a0b\u5e8f"}]},{"@type":"WebSite","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#website","url":"https:\/\/www.silicloud.com\/zh\/blog\/","name":"Blog - Silicon Cloud","description":"","inLanguage":"zh-Hans"},{"@type":"Person","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/cb5556d2501da73d864cac945e8d9461","name":"\u6e05, \u626c","image":{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/image\/","url":"https:\/\/secure.gravatar.com\/avatar\/32a4239de8ff29adace466261d309424a1e5fe9f7e3036bf89fe03f2e3dbe717?s=96&d=mm&r=g","contentUrl":"https:\/\/secure.gravatar.com\/avatar\/32a4239de8ff29adace466261d309424a1e5fe9f7e3036bf89fe03f2e3dbe717?s=96&d=mm&r=g","caption":"\u6e05, \u626c"},"url":"https:\/\/www.silicloud.com\/zh\/blog\/author\/qingyang\/"},{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e6%88%91%e5%b0%9d%e8%af%95%e4%bd%bf%e7%94%a8azure-kubernetes-service-aks%e5%92%8cconfluent-platform%e7%9a%84helm-chart%e6%9d%a5%e8%bf%90%e8%a1%8c%e5%ba%94%e7%94%a8%e7%a8%8b%e5%ba%8f%e3%80%82\/#local-main-organization-logo","url":"","contentUrl":"","caption":"Blog - Silicon Cloud"}]}},"_links":{"self":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/46806","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/users\/9"}],"replies":[{"embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/comments?post=46806"}],"version-history":[{"count":2,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/46806\/revisions"}],"predecessor-version":[{"id":84532,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/46806\/revisions\/84532"}],"wp:attachment":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/media?parent=46806"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/categories?post=46806"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/tags?post=46806"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}
$ kubectl get pod -n akscp01\r\n\r\nNAME READY STATUS RESTARTS AGE\r\ncp600-cp-control-center-5b55c5676f-tn5w9 1\/1 Running 3 3m46s\r\ncp600-cp-kafka-0 2\/2 Running 1 3m46s\r\ncp600-cp-kafka-1 2\/2 Running 0 3m8s\r\ncp600-cp-kafka-2 2\/2 Running 0 2m46s\r\ncp600-cp-kafka-connect-764c9bd6cd-n84qw 2\/2 Running 3 3m46s\r\ncp600-cp-ksql-server-5948c75b8b-dnfcm 2\/2 Running 4 3m46s\r\ncp600-cp-schema-registry-5d79b8c57-r4r5p 2\/2 Running 3 3m46s\r\ncp600-cp-zookeeper-0 2\/2 Running 0 3m46s\r\ncp600-cp-zookeeper-1 2\/2 Running 0 3m8s\r\ncp600-cp-zookeeper-2 2\/2 Running 0 2m32s\r\ncp600db-influxdb-5ff9b5cfbc-zkvjb 1\/1 Running 0 33m\r\ncp600gf-grafana-59cff8f44b-rwlwx 1\/1 Running 0 13m\r\ncp600mq-rabbitmq-0 1\/1 Running 0 6m22s\r\n<\/code><\/pre>\n
\n\u521b\u5efa Kafka \u4e3b\u9898<\/h3>\n## Kafka-client \u3078\u306e\u63a5\u7d9a\r\n$ kubectl exec -it kafka-client -n akscp01 -- \/bin\/bash\r\n\r\n## \u74b0\u5883\u5909\u6570\u306e\u5b9a\u7fa9\r\n$ export RELEASE_NAME=cp600\r\n$ export ZOOKEEPERS=${RELEASE_NAME}-cp-zookeeper:2181\r\n\r\n## topic_201 \/ topic_202 \u306e\u4f5c\u6210\r\n$ kafka-topics --zookeeper $ZOOKEEPERS --create --topic topic_201 --partitions 3 --replication-factor 1\r\n$ kafka-topics --zookeeper $ZOOKEEPERS --create --topic topic_202 --partitions 3 --replication-factor 1\r\n\r\n## topic \u306e\u78ba\u8a8d\r\n$ kafka-topics --zookeeper $ZOOKEEPERS --list\r\n<\/code><\/pre>\n
\nKSQL \u7684\u914d\u7f6e<\/h3>\n## Ksql-client \u3078\u306e\u63a5\u7d9a\r\n$ kubectl exec -it ksql-client -n akscp01 -- \/bin\/bash\r\n\r\n## \u74b0\u5883\u5909\u6570\u306e\u5b9a\u7fa9\r\n$ export RELEASE_NAME=cp600\r\n$ export KSQLDB=${RELEASE_NAME}-cp-ksql-server:8088\r\n\r\n## KsqlDB \u3078\u306e\u63a5\u7d9a\r\n$ ksql http:\/\/$KSQLDB\r\n\r\n## topic \u306e\u78ba\u8a8d\r\nksql> list topics;\r\n\r\n Kafka Topic | Partitions | Partition Replicas \r\n-----------------------------------------------------------------\r\n cp600-cp-kafka-connect-config | 1 | 3 \r\n cp600-cp-kafka-connect-offset | 25 | 3 \r\n cp600-cp-kafka-connect-status | 5 | 3 \r\n topic_201 | 3 | 1 \r\n topic_202 | 3 | 1 \r\n-----------------------------------------------------------------\r\n\r\n## stream_201 \/ stream_202 \u306e\u4f5c\u6210\r\nksql> CREATE STREAM stream_201 (id BIGINT, time VARCHAR, proc VARCHAR, section VARCHAR, iot_num VARCHAR, iot_state VARCHAR, vol_1 DOUBLE, vol_2 DOUBLE) WITH (KAFKA_TOPIC = 'topic_201', VALUE_FORMAT='JSON'); \r\n\r\nksql> CREATE STREAM stream_202 WITH (KAFKA_TOPIC = 'topic_202', VALUE_FORMAT='JSON') AS SELECT s201.section as section, s201.time as zztime, s201.proc as proc, s201.iot_num as iot_num, s201.iot_state as iot_state, s201.vol_1 as vol_1, s201.vol_2 as vol_2 FROM stream_201 s201 WHERE section='E' OR section='C' OR section='W'; \r\n\r\n## stream \u306e\u78ba\u8a8d\r\nksql> show streams;\r\n\r\n Stream Name | Kafka Topic | Format \r\n------------------------------------\r\n STREAM_201 | topic_201 | JSON \r\n STREAM_202 | topic_202 | JSON \r\n------------------------------------\r\n<\/code><\/pre>\n
\n\u8fde\u7ebf\u5668\u7684\u8bbe\u7f6e<\/h3>\n
\u4f7f\u7528\u4e86ACR\u7684\u5bb9\u5668\u6620\u50cf\uff0c\u6240\u4ee5\u9700\u8981\u786e\u8ba4\u662f\u5426\u5df2\u5b89\u88c5\u4e86RabbitMQ\/InfluxDB\u7684\u8fde\u63a5\u5668\u63d2\u4ef6\u3002<\/p>\n
$ kubectl port-forward --address localhost --namespace akscp01 svc\/cp600-cp-kafka-connect 8083:8083\r\nForwarding from 127.0.0.1:8083 -> 8083\r\nForwarding from [::1]:8083 -> 8083\r\n\r\n\u203b CTRL+C \u3067\u7d42\u4e86\u3067\u304d\u307e\u3059\r\n<\/code><\/pre>\n\u6253\u5f00\u53e6\u4e00\u4e2a\u7ec8\u7aef\u7a97\u53e3\uff0c\u786e\u8ba4RabbitMQSourceConnector\u548cInfluxDBSinkConnector\u7684\u63d2\u4ef6\u5df2\u7ecf\u5b58\u5728\u3002<\/p>\n
$ curl http:\/\/localhost:8083\/connector-plugins | jq \r\n\r\n % Total % Received % Xferd Average Speed Time Time Time Current\r\n Dload Upload Total Spent Left Speed\r\n100 793 100 793 0 0 6007 0 --:--:-- --:--:-- --:--:-- 5962\r\n[\r\n {\r\n \"class\": \"io.confluent.connect.rabbitmq.RabbitMQSourceConnector\",\r\n \"type\": \"source\",\r\n \"version\": \"0.0.0.0\"\r\n },\r\n {\r\n \"class\": \"io.confluent.influxdb.InfluxDBSinkConnector\",\r\n \"type\": \"sink\",\r\n \"version\": \"unknown\"\r\n },\r\n \uff1a\r\n \u4e2d\u7565\r\n \uff1a\r\n]\r\n<\/code><\/pre>\n\u521b\u5efaRabbitMQSourceConnector<\/h4>\n
RabbitMQSourceConnector \u7684\u5b9a\u4e49\u6587\u4ef6\u5982\u4e0b\u6240\u793a\u3002<\/p>\n
{<\/span>\r\n \"name\"<\/span> :<\/span> \"RabbitMQSourceConnector_1\"<\/span>,<\/span>\r\n \"config\"<\/span> :<\/span> {<\/span>\r\n \"connector.class\"<\/span> :<\/span> \"io.confluent.connect.rabbitmq.RabbitMQSourceConnector\"<\/span>,<\/span>\r\n \"tasks.max\"<\/span> :<\/span> \"1\"<\/span>,<\/span>\r\n \"value.converter\"<\/span>:<\/span> \"org.apache.kafka.connect.converters.ByteArrayConverter\"<\/span>,<\/span>\r\n \"rabbitmq.host\"<\/span>:<\/span> \"cp600mq-rabbitmq\"<\/span>,<\/span>\r\n \"rabbitmq.username\"<\/span>:<\/span> \"guest\"<\/span>,<\/span>\r\n \"rabbitmq.password\"<\/span>:<\/span> \"guest\"<\/span>,<\/span>\r\n \"rabbitmq.port\"<\/span>:<\/span> \"5672\"<\/span>,<\/span>\r\n \"kafka.topic\"<\/span>:<\/span> \"topic_201\"<\/span>,<\/span>\r\n \"rabbitmq.queue\"<\/span>:<\/span> \"IoTHub\"<\/span>\r\n }<\/span>\r\n}<\/span>\r\n<\/code><\/pre>\n\u521b\u5efa\u4e00\u4e2a\u65b0\u7684RabbitMQSourceConnector<\/p>\n
$ curl -s -X POST -H 'Content-Type: application\/json' --data @RabbitMQSourceConnector.json http:\/\/localhost:8083\/connectors\r\n\r\n{\"name\":\"RabbitMQSourceConnector_1\",\"config\":{\"connector.class\":\"io.confluent.connect.rabbitmq.RabbitMQSourceConnector\",\"tasks.max\":\"1\",\"value.converter\":\"org.apache.kafka.connect.converters.ByteArrayConverter\",\"rabbitmq.host\":\"cp600mq-rabbitmq\",\"rabbitmq.username\":\"guest\",\"rabbitmq.password\":\"guest\",\"rabbitmq.port\":\"5672\",\"kafka.topic\":\"topic_201\",\"rabbitmq.queue\":\"IoTHub\",\"name\":\"RabbitMQSourceConnector_1\"},\"tasks\":[],\"type\":\"source\"}\r\n<\/code><\/pre>\n\u521b\u5efa InfluxDBSinkConnector<\/h4>\n
InfluxDBSinkConnector\u7684\u5b9a\u4e49\u6587\u4ef6\u5982\u4e0b\u6240\u793a\u3002<\/p>\n
{<\/span>\r\n \"name\"<\/span>:<\/span> \"InfluxDBSinkConnector_1\"<\/span>,<\/span>\r\n \"config\"<\/span> :<\/span> {<\/span>\r\n \"value.converter.schemas.enable\"<\/span>:<\/span> \"false\"<\/span>,<\/span>\r\n \"connector.class\"<\/span>:<\/span> \"io.confluent.influxdb.InfluxDBSinkConnector\"<\/span>,<\/span>\r\n \"tasks.max\"<\/span>:<\/span> \"1\"<\/span>,<\/span>\r\n \"value.converter\"<\/span>:<\/span> \"org.apache.kafka.connect.json.JsonConverter\"<\/span>,<\/span>\r\n \"topics\"<\/span>:<\/span> \"topic_201, topic_202\"<\/span>,<\/span>\r\n \"influxdb.url\"<\/span>:<\/span> \"http:\/\/cp600db-influxdb:8086\"<\/span>,<\/span>\r\n \"influxdb.db\"<\/span>:<\/span> \"IoTSample\"<\/span>,<\/span>\r\n \"measurement.name.format\"<\/span>:<\/span> \"${topic}\"<\/span>\r\n }<\/span>\r\n}<\/span>\r\n<\/code><\/pre>\n\u521b\u5efa\u4e00\u4e2a\u65b0\u7684InfluxDBSinkConnector<\/p>\n
$ curl -s -X POST -H 'Content-Type: application\/json' --data @InfluxDBSinkConnector.json http:\/\/localhost:8083\/connectors\r\n\r\n{\"name\":\"InfluxDBSinkConnector_1\",\"config\":{\"value.converter.schemas.enable\":\"false\",\"connector.class\":\"io.confluent.influxdb.InfluxDBSinkConnector\",\"tasks.max\":\"1\",\"value.converter\":\"org.apache.kafka.connect.json.JsonConverter\",\"topics\":\"topic_201, topic_202\",\"influxdb.url\":\"http:\/\/influxdb:8086\",\"influxdb.db\":\"IoTSample\",\"measurement.name.format\":\"${topic}\",\"name\":\"InfluxDBSinkConnector_1\"},\"tasks\":[],\"type\":\"sink\"}\r\n<\/code><\/pre>\n\u8fde\u63a5\u5668\u7684\u786e\u8ba4<\/h4>\n$ curl -s \"http:\/\/localhost:8083\/connectors?expand=info&expand=status\" | \\\r\n jq '. | to_entries[] | [ .value.info.type, .key, .value.status.connector.state,.value.status.tasks[].state,.value.info.config.\"connector.class\"]|join(\":|:\")' | \\\r\n column -s : -t| sed 's\/\\\"\/\/g'| sort\r\n\r\nsink | InfluxDBSinkConnector_1 | RUNNING | RUNNING | io.confluent.influxdb.InfluxDBSinkConnector\r\nsource | RabbitMQSourceConnector_1 | RUNNING | RUNNING | io.confluent.connect.rabbitmq.RabbitMQSourceConnector\r\n<\/code><\/pre>\n
\nInfluxDB\u7684\u914d\u7f6e<\/h3>\n## influxdb \u3078\u306e\u63a5\u7d9a\r\n$ kubectl exec -it svc\/cp600db-influxdb -n akscp01 -- influx \r\n\r\nConnected to http:\/\/localhost:8086 version 1.8.5\r\nInfluxDB shell version: 1.8.5\r\n>\r\n\r\n## \u30c7\u30fc\u30bf\u30d9\u30fc\u30b9\u300cIoTSample\u300d\u306e\u4f5c\u6210\u3068\u78ba\u8a8d\r\n> create database IoTSample\r\n> show databases\r\nname: databases\r\nname\r\n----\r\n_internal\r\nIoTSample\r\n<\/code><\/pre>\n
\nGrafana\u7684\u8bbe\u7f6e<\/h3>\n
\u4e3a\u4e86\u901a\u8fc7GUI\u8fdb\u884cGrafana\u8bbe\u7f6e\uff0c\u6211\u4eec\u9700\u8981\u8fdb\u884cGrafana GUI\u7684\u7aef\u53e3\u8f6c\u53d1\u914d\u7f6e\u3002<\/p>\n
$ kubectl port-forward --address localhost --namespace akscp01 svc\/cp600gf-grafana 3000:3000\r\nForwarding from 127.0.0.1:3000 -> 3000\r\nForwarding from [::1]:3000 -> 3000\r\n\r\n\u203b CTRL+C \u3067\u7d42\u4e86\u3067\u304d\u307e\u3059\r\n<\/code><\/pre>\n\u5c06\u5728\u8fd9\u7bc7\u6587\u7ae0\u4e2d\u8fdb\u884c”\u8fde\u63a5Grafana\u548cInfluxDB\u7684\u8bbe\u7f6e”\u548c”\u521b\u5efaGrafana\u4eea\u8868\u677f”\u7684\u914d\u7f6e\u3002
\n\u4f46\u662f\uff0c\u8bf7\u5c06URL\u8bbe\u7f6e\u503c\u4ecehttp:\/\/influxdb:8086\u66f4\u6539\u4e3ahttp:\/\/cp600db-influxdb:8086\u3002<\/p>\n
RabbitMQ\u7684\u914d\u7f6e<\/h3>\n
\u7531\u4e8e\u4f7f\u7528\u4e86ACR\u7684\u5bb9\u5668\u6620\u50cf\uff0c\u6240\u4ee5\u6ca1\u6709\u4efb\u4f55\u914d\u7f6e\u4f4d\u7f6e\u3002<\/p>\n
\n\u5e94\u7528\u7a0b\u5e8f\u7684\u8fd0\u884c\u786e\u8ba4<\/h2>\n\u8bbe\u7f6e\u7aef\u53e3\u8f6c\u53d1<\/h3>\n
\u7531\u4e8e\u5bb9\u5668\u5e94\u7528\u7a0b\u5e8f\u4e0d\u8fdb\u884c\u5916\u90e8\u516c\u5f00\uff0c\u6240\u4ee5\u9700\u8981\u5bf9\u5145\u5f53\u5916\u90e8\u63a5\u53e3\u7684\u5bb9\u5668\u5e94\u7528\u7a0b\u5e8f rabbitmq \u548c grafana \u8fdb\u884c\u7aef\u53e3\u8f6c\u53d1\u7684\u8bbe\u7f6e\u3002<\/p>\n
$ kubectl port-forward --address localhost --namespace akscp01 svc\/cp600gf-grafana 3000:3000 &\r\n$ kubectl port-forward --address localhost --namespace akscp01 svc\/cp600mq-rabbitmq 5672:5672 &\r\n<\/code><\/pre>\n\u5e94\u7528\u7a0b\u5e8f\u7684\u8fd0\u884c<\/h3>\n
\u4e0e”\u5b9e\u65f6\u53ef\u89c6\u5316\u901a\u8fc7Grafana\u4eea\u8868\u76d8”\u4e2d\u63d0\u5230\u7684\u76f8\u540c\uff0c\u6211\u4eec\u53ef\u4ee5\u901a\u8fc7\u672c\u5730\u7ec8\u7aef\u6267\u884cIoT\u6570\u636e\u751f\u6210\u7a0b\u5e8f\u3002\u6211\u4eec\u751f\u6210\u4e86100\u6761\u6570\u636e\uff0c\u6bcf\u79d2\u751f\u6210\u4e00\u6761\u3002<\/p>\n
$ python IoTSampleData-v5.py --mode mq --count 100 --wait 1\r\n<\/code><\/pre>\n<\/div>\n
\n\u6574\u7406\u4e8b\u540e\u7684\u5de5\u4f5c<\/h2>\n\u505c\u6b62\u7aef\u53e3\u8f6c\u53d1<\/h3>\n## \u8a72\u5f53\u306e\u30d7\u30ed\u30bb\u30b9\u3092\u691c\u7d22\u3057\u307e\u3059\r\n$ ps -axl | grep kubectl \r\n 501 35260 8527 4006 0 31 5 5052880 34332 - SN 0 ttys000 0:00.23 kubectl port-forward --address localhost --namespace akscp01 svc\/cp600gf-grafana 3000:3000\r\n 501 35261 8527 4006 0 31 5 5053160 33008 - SN 0 ttys000 0:00.20 kubectl port-forward --address localhost --namespace akscp01 svc\/cp600mq-rabbitmq 5672:5672\r\n 501 35276 18433 4006 0 31 0 4399480 828 - S+ 0 ttys002 0:00.00 grep kubectl\r\n\r\n## \u8a72\u5f53\u306e\u30d7\u30ed\u30bb\u30b9\u3092 kill \u3057\u307e\u3059\r\n$ kill 35260 \r\n$ kill 35261\r\n<\/code><\/pre>\n\u5378\u8f7dPod<\/h3>\n$ helm delete cp600gf -n akscp01\r\n$ helm delete cp600db -n akscp01\r\n$ helm delete cp600mq -n akscp01\r\n$ helm delete cp600 -n akscp01\r\n<\/code><\/pre>\n\u5220\u9664\u547d\u540d\u7a7a\u95f4<\/h3>\n$ kubectl delete namespace akscp01\r\n<\/code><\/pre>\n
\n\u603b\u7ed3<\/h2>\n
\u6211\u4ee5\u76f8\u5f53\u571f\u6c14\u7684\u65b9\u5f0f\u5f3a\u884c\u5b9e\u73b0\u4e86\u5bb9\u5668\u5e94\u7528\u7a0b\u5e8f\uff0c\u4f46\u6211\u5e0c\u671b\u82b1\u70b9\u65f6\u95f4\uff0c\u5229\u7528 ConfigMap \u548c\u5404\u79cd\u914d\u7f6e\u6587\u4ef6\u52a0\u8f7d\u7b49\u65b9\u6cd5\uff0c\u8ffd\u6c42\u65f6\u5c1a\u7684\u5b9e\u73b0\u65b9\u5f0f\u3002<\/p>\n
\n\u672c\u8bfe\u9898\u7684\u6b65\u9aa4\u4fe1\u606f<\/h3>\n
\u7b2c\u4e00\u6b65\uff1a\u5728AKS\u4e0a\u6784\u5efaConfluent\u5e73\u53f0\u73af\u5883
\n\u7b2c\u4e8c\u6b65\uff1a\u5728AKS\u4e0a\u8fd0\u884c\u5bb9\u5668\u5e94\u7528\u7a0b\u5e8f<\/p>\n
\u53c2\u8003\u8d44\u6599<\/h3>\n
\u611f\u8c22\u60a8\u63d0\u4f9b\u7684\u4ee5\u4e0b\u4fe1\u606f\u3002\u6211\u5c06\u53c2\u8003\u5b83\u4eec\u3002\u63a8\u8350\u4f7f\u7528Helm v3\u3002
\nHelm\u662f\u7528\u4e8eKubernetes\u7684\u4e8b\u5b9e\u4e0a\u7684\u6807\u51c6\u90e8\u7f72\u5de5\u5177\u3002<\/p>\n","protected":false},"excerpt":{"rendered":"
\u6982\u8981 – \u7b80\u8981\u7248\u7684\u63cf\u8ff0 \u6211\u53c2\u8003\u4e86\u8fd9\u7bc7\u6587\u7ae0\uff0c\u7528\u4e00\u70b9\u70b9\u7406\u89e3\u7684 Helm v3\uff0c\u603b\u7ed3\u4e86\u4f7f\u7528 Confue […]<\/p>\n","protected":false},"author":9,"featured_media":0,"comment_status":"closed","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[],"class_list":["post-46806","post","type-post","status-publish","format-standard","hentry","category-uncategorized"],"yoast_head":"\n
\u6211\u5c1d\u8bd5\u4f7f\u7528Azure Kubernetes Service (AKS)\u548cConfluent Platform\u7684Helm Chart\u6765\u8fd0\u884c\u5e94\u7528\u7a0b\u5e8f - Blog - Silicon Cloud<\/title>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"https:\/\/www.silicloud.com\/zh\/blog\/\u6211\u5c1d\u8bd5\u4f7f\u7528azure-kubernetes-service-aks\u548cconfluent-platform\u7684helm-chart\u6765\u8fd0\u884c\u5e94\u7528\u7a0b\u5e8f\u3002\/\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"\u6211\u5c1d\u8bd5\u4f7f\u7528Azure Kubernetes Service (AKS)\u548cConfluent Platform\u7684Helm Chart\u6765\u8fd0\u884c\u5e94\u7528\u7a0b\u5e8f\" \/>\n<meta property=\"og:description\" content=\"\u6982\u8981 – \u7b80\u8981\u7248\u7684\u63cf\u8ff0 \u6211\u53c2\u8003\u4e86\u8fd9\u7bc7\u6587\u7ae0\uff0c\u7528\u4e00\u70b9\u70b9\u7406\u89e3\u7684 Helm v3\uff0c\u603b\u7ed3\u4e86\u4f7f\u7528 Confue […]\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.silicloud.com\/zh\/blog\/\u6211\u5c1d\u8bd5\u4f7f\u7528azure-kubernetes-service-aks\u548cconfluent-platform\u7684helm-chart\u6765\u8fd0\u884c\u5e94\u7528\u7a0b\u5e8f\u3002\/\" \/>\n<meta property=\"og:site_name\" content=\"Blog - Silicon Cloud\" \/>\n<meta property=\"article:published_time\" content=\"2022-11-22T14:00:20+00:00\" \/>\n<meta property=\"article:modified_time\" content=\"2024-04-29T01:47:04+00:00\" \/>\n<meta property=\"og:image\" content=\"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d7b0c913a08637a697f46\/2-0.png\" \/>\n<meta name=\"author\" content=\"\u6e05, \u626c\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"\u4f5c\u8005\" \/>\n\t<meta name=\"twitter:data1\" content=\"\u6e05, \u626c\" \/>\n\t<meta name=\"twitter:label2\" content=\"\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4\" \/>\n\t<meta name=\"twitter:data2\" content=\"4 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e6%88%91%e5%b0%9d%e8%af%95%e4%bd%bf%e7%94%a8azure-kubernetes-service-aks%e5%92%8cconfluent-platform%e7%9a%84helm-chart%e6%9d%a5%e8%bf%90%e8%a1%8c%e5%ba%94%e7%94%a8%e7%a8%8b%e5%ba%8f%e3%80%82\/\",\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e6%88%91%e5%b0%9d%e8%af%95%e4%bd%bf%e7%94%a8azure-kubernetes-service-aks%e5%92%8cconfluent-platform%e7%9a%84helm-chart%e6%9d%a5%e8%bf%90%e8%a1%8c%e5%ba%94%e7%94%a8%e7%a8%8b%e5%ba%8f%e3%80%82\/\",\"name\":\"\u6211\u5c1d\u8bd5\u4f7f\u7528Azure Kubernetes Service (AKS)\u548cConfluent Platform\u7684Helm Chart\u6765\u8fd0\u884c\u5e94\u7528\u7a0b\u5e8f - Blog - Silicon Cloud\",\"isPartOf\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#website\"},\"datePublished\":\"2022-11-22T14:00:20+00:00\",\"dateModified\":\"2024-04-29T01:47:04+00:00\",\"author\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/cb5556d2501da73d864cac945e8d9461\"},\"breadcrumb\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e6%88%91%e5%b0%9d%e8%af%95%e4%bd%bf%e7%94%a8azure-kubernetes-service-aks%e5%92%8cconfluent-platform%e7%9a%84helm-chart%e6%9d%a5%e8%bf%90%e8%a1%8c%e5%ba%94%e7%94%a8%e7%a8%8b%e5%ba%8f%e3%80%82\/#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.silicloud.com\/zh\/blog\/%e6%88%91%e5%b0%9d%e8%af%95%e4%bd%bf%e7%94%a8azure-kubernetes-service-aks%e5%92%8cconfluent-platform%e7%9a%84helm-chart%e6%9d%a5%e8%bf%90%e8%a1%8c%e5%ba%94%e7%94%a8%e7%a8%8b%e5%ba%8f%e3%80%82\/\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e6%88%91%e5%b0%9d%e8%af%95%e4%bd%bf%e7%94%a8azure-kubernetes-service-aks%e5%92%8cconfluent-platform%e7%9a%84helm-chart%e6%9d%a5%e8%bf%90%e8%a1%8c%e5%ba%94%e7%94%a8%e7%a8%8b%e5%ba%8f%e3%80%82\/#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/www.silicloud.com\/zh\/blog\/\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"\u6211\u5c1d\u8bd5\u4f7f\u7528Azure Kubernetes Service (AKS)\u548cConfluent Platform\u7684Helm Chart\u6765\u8fd0\u884c\u5e94\u7528\u7a0b\u5e8f\"}]},{\"@type\":\"WebSite\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#website\",\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/\",\"name\":\"Blog - Silicon Cloud\",\"description\":\"\",\"inLanguage\":\"zh-Hans\"},{\"@type\":\"Person\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/cb5556d2501da73d864cac945e8d9461\",\"name\":\"\u6e05, \u626c\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/secure.gravatar.com\/avatar\/32a4239de8ff29adace466261d309424a1e5fe9f7e3036bf89fe03f2e3dbe717?s=96&d=mm&r=g\",\"contentUrl\":\"https:\/\/secure.gravatar.com\/avatar\/32a4239de8ff29adace466261d309424a1e5fe9f7e3036bf89fe03f2e3dbe717?s=96&d=mm&r=g\",\"caption\":\"\u6e05, \u626c\"},\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/author\/qingyang\/\"},{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e6%88%91%e5%b0%9d%e8%af%95%e4%bd%bf%e7%94%a8azure-kubernetes-service-aks%e5%92%8cconfluent-platform%e7%9a%84helm-chart%e6%9d%a5%e8%bf%90%e8%a1%8c%e5%ba%94%e7%94%a8%e7%a8%8b%e5%ba%8f%e3%80%82\/#local-main-organization-logo\",\"url\":\"\",\"contentUrl\":\"\",\"caption\":\"Blog - Silicon Cloud\"}]}<\/script>\n<!-- \/ Yoast SEO Premium plugin. -->","yoast_head_json":{"title":"\u6211\u5c1d\u8bd5\u4f7f\u7528Azure Kubernetes Service (AKS)\u548cConfluent Platform\u7684Helm Chart\u6765\u8fd0\u884c\u5e94\u7528\u7a0b\u5e8f - Blog - Silicon Cloud","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"https:\/\/www.silicloud.com\/zh\/blog\/\u6211\u5c1d\u8bd5\u4f7f\u7528azure-kubernetes-service-aks\u548cconfluent-platform\u7684helm-chart\u6765\u8fd0\u884c\u5e94\u7528\u7a0b\u5e8f\u3002\/","og_locale":"zh_CN","og_type":"article","og_title":"\u6211\u5c1d\u8bd5\u4f7f\u7528Azure Kubernetes Service (AKS)\u548cConfluent Platform\u7684Helm Chart\u6765\u8fd0\u884c\u5e94\u7528\u7a0b\u5e8f","og_description":"\u6982\u8981 – \u7b80\u8981\u7248\u7684\u63cf\u8ff0 \u6211\u53c2\u8003\u4e86\u8fd9\u7bc7\u6587\u7ae0\uff0c\u7528\u4e00\u70b9\u70b9\u7406\u89e3\u7684 Helm v3\uff0c\u603b\u7ed3\u4e86\u4f7f\u7528 Confue […]","og_url":"https:\/\/www.silicloud.com\/zh\/blog\/\u6211\u5c1d\u8bd5\u4f7f\u7528azure-kubernetes-service-aks\u548cconfluent-platform\u7684helm-chart\u6765\u8fd0\u884c\u5e94\u7528\u7a0b\u5e8f\u3002\/","og_site_name":"Blog - Silicon Cloud","article_published_time":"2022-11-22T14:00:20+00:00","article_modified_time":"2024-04-29T01:47:04+00:00","og_image":[{"url":"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d7b0c913a08637a697f46\/2-0.png"}],"author":"\u6e05, \u626c","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"\u6e05, \u626c","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"4 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e6%88%91%e5%b0%9d%e8%af%95%e4%bd%bf%e7%94%a8azure-kubernetes-service-aks%e5%92%8cconfluent-platform%e7%9a%84helm-chart%e6%9d%a5%e8%bf%90%e8%a1%8c%e5%ba%94%e7%94%a8%e7%a8%8b%e5%ba%8f%e3%80%82\/","url":"https:\/\/www.silicloud.com\/zh\/blog\/%e6%88%91%e5%b0%9d%e8%af%95%e4%bd%bf%e7%94%a8azure-kubernetes-service-aks%e5%92%8cconfluent-platform%e7%9a%84helm-chart%e6%9d%a5%e8%bf%90%e8%a1%8c%e5%ba%94%e7%94%a8%e7%a8%8b%e5%ba%8f%e3%80%82\/","name":"\u6211\u5c1d\u8bd5\u4f7f\u7528Azure Kubernetes Service (AKS)\u548cConfluent Platform\u7684Helm Chart\u6765\u8fd0\u884c\u5e94\u7528\u7a0b\u5e8f - Blog - Silicon Cloud","isPartOf":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/#website"},"datePublished":"2022-11-22T14:00:20+00:00","dateModified":"2024-04-29T01:47:04+00:00","author":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/cb5556d2501da73d864cac945e8d9461"},"breadcrumb":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e6%88%91%e5%b0%9d%e8%af%95%e4%bd%bf%e7%94%a8azure-kubernetes-service-aks%e5%92%8cconfluent-platform%e7%9a%84helm-chart%e6%9d%a5%e8%bf%90%e8%a1%8c%e5%ba%94%e7%94%a8%e7%a8%8b%e5%ba%8f%e3%80%82\/#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.silicloud.com\/zh\/blog\/%e6%88%91%e5%b0%9d%e8%af%95%e4%bd%bf%e7%94%a8azure-kubernetes-service-aks%e5%92%8cconfluent-platform%e7%9a%84helm-chart%e6%9d%a5%e8%bf%90%e8%a1%8c%e5%ba%94%e7%94%a8%e7%a8%8b%e5%ba%8f%e3%80%82\/"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e6%88%91%e5%b0%9d%e8%af%95%e4%bd%bf%e7%94%a8azure-kubernetes-service-aks%e5%92%8cconfluent-platform%e7%9a%84helm-chart%e6%9d%a5%e8%bf%90%e8%a1%8c%e5%ba%94%e7%94%a8%e7%a8%8b%e5%ba%8f%e3%80%82\/#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/www.silicloud.com\/zh\/blog\/"},{"@type":"ListItem","position":2,"name":"\u6211\u5c1d\u8bd5\u4f7f\u7528Azure Kubernetes Service (AKS)\u548cConfluent Platform\u7684Helm Chart\u6765\u8fd0\u884c\u5e94\u7528\u7a0b\u5e8f"}]},{"@type":"WebSite","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#website","url":"https:\/\/www.silicloud.com\/zh\/blog\/","name":"Blog - Silicon Cloud","description":"","inLanguage":"zh-Hans"},{"@type":"Person","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/cb5556d2501da73d864cac945e8d9461","name":"\u6e05, \u626c","image":{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/image\/","url":"https:\/\/secure.gravatar.com\/avatar\/32a4239de8ff29adace466261d309424a1e5fe9f7e3036bf89fe03f2e3dbe717?s=96&d=mm&r=g","contentUrl":"https:\/\/secure.gravatar.com\/avatar\/32a4239de8ff29adace466261d309424a1e5fe9f7e3036bf89fe03f2e3dbe717?s=96&d=mm&r=g","caption":"\u6e05, \u626c"},"url":"https:\/\/www.silicloud.com\/zh\/blog\/author\/qingyang\/"},{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e6%88%91%e5%b0%9d%e8%af%95%e4%bd%bf%e7%94%a8azure-kubernetes-service-aks%e5%92%8cconfluent-platform%e7%9a%84helm-chart%e6%9d%a5%e8%bf%90%e8%a1%8c%e5%ba%94%e7%94%a8%e7%a8%8b%e5%ba%8f%e3%80%82\/#local-main-organization-logo","url":"","contentUrl":"","caption":"Blog - Silicon Cloud"}]}},"_links":{"self":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/46806","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/users\/9"}],"replies":[{"embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/comments?post=46806"}],"version-history":[{"count":2,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/46806\/revisions"}],"predecessor-version":[{"id":84532,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/46806\/revisions\/84532"}],"wp:attachment":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/media?parent=46806"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/categories?post=46806"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/tags?post=46806"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}