{"id":46749,"date":"2023-05-25T10:38:37","date_gmt":"2023-07-19T00:37:58","guid":{"rendered":"https:\/\/www.silicloud.com\/zh\/blog\/46749-2\/"},"modified":"2024-04-30T05:53:01","modified_gmt":"2024-04-29T21:53:01","slug":"46749-2","status":"publish","type":"post","link":"https:\/\/www.silicloud.com\/zh\/blog\/46749-2\/","title":{"rendered":""},"content":{"rendered":"

\u6982\u8981<\/h2>\n

Kafka\u306b\u9b45\u305b\u3089\u308c\u3066\u3001\u3068\u308a\u3042\u3048\u305a\u624b\u5143\u306e\u30de\u30b7\u30f3\u3067\u52d5\u304b\u3057\u3066\u307f\u307e\u3057\u3087\u3046\u304b\u3001\u3001\u3001\u3068\u3001\u30a4\u30f3\u30d5\u30e9\u3057\u304b\u77e5\u3089\u306a\u3044SE\u304cMacBookPro\u3092\u65b0\u305f\u306b\u8cfc\u5165\u3057\u3001Qiita\u7b49\u306b\u30a2\u30c3\u30d7\u3055\u308c\u3066\u3044\u308b\u8af8\u5148\u8f29\u65b9\u306e\u8a18\u4e8b\u3092\u53c2\u8003\u306b\u3055\u305b\u3066\u3044\u305f\u3060\u304d\u3001\u30ed\u30fc\u30ab\u30eb\u306eDocker\u74b0\u5883\u3067Kafka\u3092\u52d5\u4f5c\u78ba\u8a8d\u3057\u305f\u307e\u3067\u306e\u624b\u9806\u3092\u3001\u904e\u53bb\u306b\uff17\u56de\u306b\u5206\u3051\u8a18\u8f09\u3057\u307e\u3057\u305f\u3002\u305d\u306e\uff17\u56de\u306b\u8a18\u4e8b\u306b\u3064\u3044\u3066\u306f\u3053\u3061\u3089\u304b\u3089\u53c2\u7167\u304f\u3060\u3055\u3044\u3002
\n\u4eca\u56de\u306f\u3001\u305d\u306eDocker\u74b0\u5883\u3067\u52d5\u3044\u3066\u3044\u305fKafka\u691c\u8a3c\u30b7\u30b9\u30c6\u30e0\u306e docker-compose.yml \u3092 Kubernetes\u74b0\u5883\u306e\u30de\u30cb\u30d5\u30a1\u30b9\u30c8\uff08yaml\u5f62\u5f0f\uff09\u3067\u3069\u306e\u3088\u3046\u306b\u5b9a\u7fa9\u3057\u76f4\u3059\u306e\u304b\u3092\u78ba\u8a8d\u3057\u307e\u3057\u305f\u3002<\/p>\n

\"kafka-k8s-1.png\"<\/div>\n

\u4e0a\u56f3\u306b\u5f93\u3044\u3001\u30de\u30cb\u30d5\u30a7\u30b9\u30c8\u3092\u5b9a\u7fa9\u3057\u3066\u3044\u307e\u3059\u3002<\/p>\n

\n
PodManifestProducer\/Comsumerpython-iot-dev.yamlzookeeperzookeeper-v1.yamlbrokerbroker-v1.yamlksql-server\/ksql-cliksql-v1.yaml<\/div>\n<\/div>\n

\u306a\u304a\u3001Producwe\/Consumer \u306b\u3064\u3044\u3066\u306f\u3001Docker Image \u4f5c\u6210\u306e\u305f\u3081\u3001Dockerfile \u3082\u5b9a\u7fa9\u3057\u3066\u3044\u307e\u3059\u3002<\/p>\n

\u5b9f\u884c\u74b0\u5883<\/h2>\n

macOS Big Sur 11.1
\nDocker version 20.10.2, build 2291f61
\nPython 3.8.3<\/p>\n

Kubernetes\u74b0\u5883<\/h2>\n

Diamanti spektra kubernetes
\nHarbor
\nwindows DNS<\/p>\n

\u4f5c\u696d\u306e\u30c7\u30a3\u30ec\u30af\u30c8\u30ea\u69cb\u6210<\/h2>\n

\u4f5c\u696d\u306e\u30c7\u30a3\u30ec\u30af\u30c8\u30ea\u69cb\u6210\u306f\u4ee5\u4e0b\u3068\u306a\u308a\u307e\u3059<\/p>\n

$ tree                \r\n.\r\n\u251c\u2500\u2500 Dockerfile\r\n\u251c\u2500\u2500 broker-v1.yaml\r\n\u251c\u2500\u2500 ksql-v1.yaml\r\n\u251c\u2500\u2500 opt\r\n\u2502\u00a0\u00a0 \u251c\u2500\u2500 Consumer-v1.py\r\n\u2502\u00a0\u00a0 \u2514\u2500\u2500 Producer-v1.py\r\n\u251c\u2500\u2500 python-iot-dev.yaml\r\n\u251c\u2500\u2500 requirements.txt\r\n\u2514\u2500\u2500 zookeeper-v1.yaml\r\n<\/code><\/pre>\n
Producer\/Consumer \u306e Dockerfile<\/h2>\n
Producer\/Consumer \u3067\u5171\u901a\u306eDocker Image \u3068\u306a\u308a\u307e\u3059\u3002
\nProducer\/Consumer\u3067\u7a3c\u50cd\u3055\u305b\u308b\u30d7\u30ed\u30b0\u30e9\u30e0\u3092\u30b3\u30d4\u30fc\u3057\u3066\u304a\u304d\u307e\u3059\u3002<\/p>\n
FROM<\/span> python:3.8.3-slim<\/span>\r\nUSER<\/span> root<\/span>\r\n\r\nRUN <\/span>apt-get update\r\nRUN <\/span>apt-get -y<\/span> install <\/span>locales &&<\/span> localedef -f<\/span> UTF-8 -i<\/span> ja_JP ja_JP.UTF-8\r\n\r\nENV<\/span> LANG ja_JP.UTF-8<\/span>\r\nENV<\/span> LANGUAGE ja_JP:ja<\/span>\r\nENV<\/span> LC_ALL ja_JP.UTF-8<\/span>\r\nENV<\/span> TZ JST-9<\/span>\r\nENV<\/span> TERM xterm<\/span>\r\n\r\nRUN <\/span>apt-get install<\/span> -y<\/span> vim less\r\nRUN <\/span>apt-get install<\/span> -y<\/span> dnsutils iputils-ping net-tools procps netcat\r\n\r\nCOPY<\/span> requirements.txt .<\/span>\r\nRUN <\/span>pip install<\/span> --upgrade<\/span> pip\r\nRUN <\/span>pip install<\/span> --upgrade<\/span> setuptools\r\nRUN <\/span>pip install<\/span> -r<\/span> requirements.txt\r\n\r\nWORKDIR<\/span> \/opt\/app<\/span>\r\nCOPY<\/span> .\/opt\/*.py \/opt\/app\/.<\/span>\r\n<\/code><\/pre>\n
\u30de\u30cb\u30d5\u30a7\u30b9\u30c8<\/h2>\n
zookeeper\u3001broker\u3001 ksql-server\/ksql-cli\u3001Producer\/Comsumer \u306e\uff14\u3064\u306b\u5206\u3051\u3066\u5b9a\u7fa9\u3057\u307e\u3057\u305f\u3002<\/p>\n
### Producer\/Comsumer ###<\/span>\r\napiVersion<\/span>:<\/span> apps\/v1<\/span>\r\nkind<\/span>:<\/span> Deployment<\/span>\r\nmetadata<\/span>:<\/span>\r\n  name<\/span>:<\/span> iot<\/span>\r\n  namespace<\/span>:<\/span> spektra-demo-tenant01-project-nw-kafka<\/span>\r\n  labels<\/span>:<\/span>\r\n    app<\/span>:<\/span> iot<\/span>\r\nspec<\/span>:<\/span>\r\n  replicas<\/span>:<\/span> 2<\/span>\r\n  selector<\/span>:<\/span>\r\n    matchLabels<\/span>:<\/span>\r\n      app<\/span>:<\/span> iot<\/span>\r\n  template<\/span>:<\/span>\r\n    metadata<\/span>:<\/span>\r\n      namespace<\/span>:<\/span> spektra-demo-tenant01-project-nw-kafka<\/span>\r\n      labels<\/span>:<\/span>\r\n        app<\/span>:<\/span> iot<\/span>\r\n    spec<\/span>:<\/span>\r\n      containers<\/span>:<\/span>\r\n      -<\/span> name<\/span>:<\/span> iot-dev<\/span>\r\n        resources<\/span>:<\/span>\r\n          limits<\/span>:<\/span>\r\n            cpu<\/span>:<\/span> 1000m<\/span>\r\n            memory<\/span>:<\/span> 1Gi<\/span>\r\n        image<\/span>:<\/span> harbor.nwdiamanti.local\/nw-kafka\/python-iot:1.0.0<\/span>\r\n        tty<\/span>:<\/span> true<\/span>\r\n      dnsConfig<\/span>:<\/span>\r\n        options<\/span>:<\/span>\r\n        -<\/span> name<\/span>:<\/span> ndots<\/span>\r\n          value<\/span>:<\/span> \"<\/span>1\"<\/span>\r\n      imagePullSecrets<\/span>:<\/span>\r\n      -<\/span> name<\/span>:<\/span> harbor<\/span>\r\n<\/code><\/pre>\n
### zookeeper ###<\/span>\r\napiVersion<\/span>:<\/span> v1<\/span>\r\nkind<\/span>:<\/span> Service<\/span>\r\nmetadata<\/span>:<\/span>\r\n  name<\/span>:<\/span> kafka-zookeeper<\/span>\r\n  namespace<\/span>:<\/span> spektra-demo-tenant01-project-nw-kafka<\/span>\r\nspec<\/span>:<\/span>\r\n  ports<\/span>:<\/span>\r\n  -<\/span> port<\/span>:<\/span> 32181<\/span>\r\n    protocol<\/span>:<\/span> TCP<\/span>\r\n    targetPort<\/span>:<\/span> 32181<\/span>\r\n  selector<\/span>:<\/span>\r\n    app<\/span>:<\/span> kafka-zookeeper<\/span>\r\n---<\/span>\r\napiVersion<\/span>:<\/span> apps\/v1<\/span>\r\nkind<\/span>:<\/span> Deployment<\/span>\r\nmetadata<\/span>:<\/span>\r\n  name<\/span>:<\/span> kafka-zookeeper<\/span>\r\n  namespace<\/span>:<\/span> spektra-demo-tenant01-project-nw-kafka<\/span>\r\n  labels<\/span>:<\/span>\r\n    app<\/span>:<\/span> kafka-zookeeper<\/span>\r\nspec<\/span>:<\/span>\r\n  replicas<\/span>:<\/span> 1<\/span>\r\n  selector<\/span>:<\/span>\r\n    matchLabels<\/span>:<\/span>\r\n      app<\/span>:<\/span> kafka-zookeeper<\/span>\r\n  template<\/span>:<\/span>\r\n    metadata<\/span>:<\/span>\r\n      namespace<\/span>:<\/span> spektra-demo-tenant01-project-nw-kafka<\/span>\r\n      labels<\/span>:<\/span>\r\n        app<\/span>:<\/span> kafka-zookeeper<\/span>\r\n    spec<\/span>:<\/span>\r\n      containers<\/span>:<\/span>\r\n      -<\/span> name<\/span>:<\/span> zookeeper<\/span>\r\n        image<\/span>:<\/span> confluentinc\/cp-zookeeper:5.5.1<\/span>\r\n        imagePullPolicy<\/span>:<\/span> Always<\/span>\r\n        resources<\/span>:<\/span>\r\n          limits<\/span>:<\/span>\r\n            cpu<\/span>:<\/span> 1000m<\/span>\r\n            memory<\/span>:<\/span> 1Gi<\/span>\r\n        env<\/span>:<\/span>\r\n        -<\/span> name<\/span>:<\/span> ZOOKEEPER_CLIENT_PORT<\/span>\r\n          value<\/span>:<\/span> \"<\/span>32181\"<\/span>\r\n        -<\/span> name<\/span>:<\/span> ZOOKEEPER_TICK_TIME<\/span>\r\n          value<\/span>:<\/span> \"<\/span>2000\"<\/span>\r\n        ports<\/span>:<\/span>\r\n        -<\/span> containerPort<\/span>:<\/span> 32181<\/span>\r\n          protocol<\/span>:<\/span> TCP<\/span>\r\n      dnsConfig<\/span>:<\/span>\r\n        options<\/span>:<\/span>\r\n        -<\/span> name<\/span>:<\/span> ndots<\/span>\r\n          value<\/span>:<\/span> \"<\/span>1\"<\/span>\r\n<\/code><\/pre>\n
### broker ###<\/span>\r\napiVersion<\/span>:<\/span> v1<\/span>\r\nkind<\/span>:<\/span> Service<\/span>\r\nmetadata<\/span>:<\/span>\r\n  name<\/span>:<\/span> kafka-broker<\/span>\r\n  namespace<\/span>:<\/span> spektra-demo-tenant01-project-nw-kafka<\/span>\r\nspec<\/span>:<\/span>\r\n  ports<\/span>:<\/span>\r\n  -<\/span> port<\/span>:<\/span> 29092<\/span>\r\n    protocol<\/span>:<\/span> TCP<\/span>\r\n    targetPort<\/span>:<\/span> 29092<\/span>\r\n  selector<\/span>:<\/span>\r\n    app<\/span>:<\/span> kafka-broker<\/span>\r\n---<\/span>\r\napiVersion<\/span>:<\/span> apps\/v1<\/span>\r\nkind<\/span>:<\/span> Deployment<\/span>\r\nmetadata<\/span>:<\/span>\r\n  name<\/span>:<\/span> kafka-broker<\/span>\r\n  namespace<\/span>:<\/span> spektra-demo-tenant01-project-nw-kafka<\/span>\r\n  labels<\/span>:<\/span>\r\n    app<\/span>:<\/span> kafka-broker<\/span>\r\nspec<\/span>:<\/span>\r\n  replicas<\/span>:<\/span> 1<\/span>\r\n  selector<\/span>:<\/span>\r\n    matchLabels<\/span>:<\/span>\r\n      app<\/span>:<\/span> kafka-broker<\/span>\r\n  template<\/span>:<\/span>\r\n    metadata<\/span>:<\/span>\r\n      namespace<\/span>:<\/span> spektra-demo-tenant01-project-nw-kafka<\/span>\r\n      labels<\/span>:<\/span>\r\n        app<\/span>:<\/span> kafka-broker<\/span>\r\n    spec<\/span>:<\/span>\r\n      containers<\/span>:<\/span>\r\n      -<\/span> name<\/span>:<\/span> broker<\/span>\r\n        image<\/span>:<\/span> confluentinc\/cp-kafka:5.5.1<\/span>\r\n        imagePullPolicy<\/span>:<\/span> Always<\/span>\r\n        resources<\/span>:<\/span>\r\n          limits<\/span>:<\/span>\r\n            cpu<\/span>:<\/span> 1000m<\/span>\r\n            memory<\/span>:<\/span> 2Gi<\/span>\r\n        env<\/span>:<\/span>\r\n        -<\/span> name<\/span>:<\/span> KAFKA_BROKER_ID<\/span>\r\n          value<\/span>:<\/span> \"<\/span>1\"<\/span>\r\n        -<\/span> name<\/span>:<\/span> KAFKA_ZOOKEEPER_CONNECT<\/span>\r\n          value<\/span>:<\/span> kafka-zookeeper:32181<\/span>\r\n        -<\/span> name<\/span>:<\/span> KAFKA_LISTENER_SECURITY_PROTOCOL_MAP<\/span>\r\n          value<\/span>:<\/span> PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT<\/span>\r\n        -<\/span> name<\/span>:<\/span> KAFKA_ADVERTISED_LISTENERS<\/span>\r\n          value<\/span>:<\/span> PLAINTEXT:\/\/broker:29092,PLAINTEXT_HOST:\/\/localhost:9092<\/span>\r\n        -<\/span> name<\/span>:<\/span> KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR<\/span>\r\n          value<\/span>:<\/span> \"<\/span>1\"<\/span>\r\n        -<\/span> name<\/span>:<\/span> CONFLUENT_SUPPORT_METRICS_ENABLE<\/span>\r\n          value<\/span>:<\/span> \"<\/span>false\"<\/span>\r\n        ports<\/span>:<\/span>\r\n        -<\/span> containerPort<\/span>:<\/span> 9092<\/span>\r\n          protocol<\/span>:<\/span> TCP<\/span>\r\n        -<\/span> containerPort<\/span>:<\/span> 29092<\/span>\r\n          protocol<\/span>:<\/span> TCP<\/span>\r\n      dnsConfig<\/span>:<\/span>\r\n        options<\/span>:<\/span>\r\n        -<\/span> name<\/span>:<\/span> ndots<\/span>\r\n          value<\/span>:<\/span> \"<\/span>1\"<\/span>\r\n<\/code><\/pre>\n
### ksql-server ###<\/span>\r\napiVersion<\/span>:<\/span> v1<\/span>\r\nkind<\/span>:<\/span> Service<\/span>\r\nmetadata<\/span>:<\/span>\r\n  name<\/span>:<\/span> kafka-ksql-server<\/span>\r\n  namespace<\/span>:<\/span> spektra-demo-tenant01-project-nw-kafka<\/span>\r\nspec<\/span>:<\/span>\r\n  ports<\/span>:<\/span>\r\n  -<\/span> port<\/span>:<\/span> 8088<\/span>\r\n    protocol<\/span>:<\/span> TCP<\/span>\r\n    targetPort<\/span>:<\/span> 8088<\/span>\r\n  selector<\/span>:<\/span>\r\n    app<\/span>:<\/span> kafka-ksql-server<\/span>\r\n---<\/span>\r\napiVersion<\/span>:<\/span> apps\/v1<\/span>\r\nkind<\/span>:<\/span> Deployment<\/span>\r\nmetadata<\/span>:<\/span>\r\n  name<\/span>:<\/span> kafka-ksql-server<\/span>\r\n  namespace<\/span>:<\/span> spektra-demo-tenant01-project-nw-kafka<\/span>\r\n  labels<\/span>:<\/span>\r\n    app<\/span>:<\/span> kafka-ksql-server<\/span>\r\nspec<\/span>:<\/span>\r\n  replicas<\/span>:<\/span> 1<\/span>\r\n  selector<\/span>:<\/span>\r\n    matchLabels<\/span>:<\/span>\r\n      app<\/span>:<\/span> kafka-ksql-server<\/span>\r\n  template<\/span>:<\/span>\r\n    metadata<\/span>:<\/span>\r\n      namespace<\/span>:<\/span> spektra-demo-tenant01-project-nw-kafka<\/span>\r\n      labels<\/span>:<\/span>\r\n        app<\/span>:<\/span> kafka-ksql-server<\/span>\r\n    spec<\/span>:<\/span>\r\n      containers<\/span>:<\/span>\r\n      -<\/span> name<\/span>:<\/span> ksql-server<\/span>\r\n        image<\/span>:<\/span> confluentinc\/cp-ksql-server:5.4.3<\/span>\r\n        imagePullPolicy<\/span>:<\/span> Always<\/span>\r\n        resources<\/span>:<\/span>\r\n          limits<\/span>:<\/span>\r\n            cpu<\/span>:<\/span> 2000m<\/span>\r\n            memory<\/span>:<\/span> 2Gi<\/span>\r\n        env<\/span>:<\/span>\r\n        -<\/span> name<\/span>:<\/span> KSQL_CONFIG_DIR<\/span>\r\n          value<\/span>:<\/span> \/etc\/ksql<\/span>\r\n        -<\/span> name<\/span>:<\/span> KSQL_LOG4J_OPTS<\/span>\r\n          value<\/span>:<\/span> -Dlog4j.configuration=file:\/etc\/ksql\/log4j-rolling.properties<\/span>\r\n        -<\/span> name<\/span>:<\/span> KSQL_BOOTSTRAP_SERVERS<\/span>\r\n          value<\/span>:<\/span> kafka-broker:29092<\/span>\r\n        -<\/span> name<\/span>:<\/span> KSQL_HOST_NAME<\/span>\r\n          value<\/span>:<\/span> ksql-server<\/span>\r\n        -<\/span> name<\/span>:<\/span> KSQL_APPLICATION_ID<\/span>\r\n          value<\/span>:<\/span> IoT-K8S-1<\/span>\r\n        -<\/span> name<\/span>:<\/span> KSQL_LISTENERS<\/span>\r\n          value<\/span>:<\/span> http:\/\/0.0.0.0:8088<\/span>\r\n        -<\/span> name<\/span>:<\/span> KSQL_CACHE_MAX_BYTES_BUFFERING<\/span>\r\n          value<\/span>:<\/span> \"<\/span>0\"<\/span>\r\n        -<\/span> name<\/span>:<\/span> KSQL_AUTO_OFFSET_RESET<\/span>\r\n          value<\/span>:<\/span> earliest<\/span>\r\n        ports<\/span>:<\/span>\r\n        -<\/span> containerPort<\/span>:<\/span> 8088<\/span>\r\n          protocol<\/span>:<\/span> TCP<\/span>\r\n      dnsConfig<\/span>:<\/span>\r\n        options<\/span>:<\/span>\r\n        -<\/span> name<\/span>:<\/span> ndots<\/span>\r\n          value<\/span>:<\/span> \"<\/span>1\"<\/span>\r\n---<\/span>\r\n### ksql-cli ###<\/span>\r\napiVersion<\/span>:<\/span> apps\/v1<\/span>\r\nkind<\/span>:<\/span> Deployment<\/span>\r\nmetadata<\/span>:<\/span>\r\n  name<\/span>:<\/span> kafka-ksql-cli<\/span>\r\n  namespace<\/span>:<\/span> spektra-demo-tenant01-project-nw-kafka<\/span>\r\n  labels<\/span>:<\/span>\r\n    app<\/span>:<\/span> kafka-ksql-cli<\/span>\r\nspec<\/span>:<\/span>\r\n  replicas<\/span>:<\/span> 1<\/span>\r\n  selector<\/span>:<\/span>\r\n    matchLabels<\/span>:<\/span>\r\n      app<\/span>:<\/span> kafka-ksql-cli<\/span>\r\n  template<\/span>:<\/span>\r\n    metadata<\/span>:<\/span>\r\n      namespace<\/span>:<\/span> spektra-demo-tenant01-project-nw-kafka<\/span>\r\n      labels<\/span>:<\/span>\r\n        app<\/span>:<\/span> kafka-ksql-cli<\/span>\r\n    spec<\/span>:<\/span>\r\n      containers<\/span>:<\/span>\r\n      -<\/span> name<\/span>:<\/span> ksql-cli<\/span>\r\n        image<\/span>:<\/span> confluentinc\/cp-ksql-cli:5.4.3<\/span>\r\n        imagePullPolicy<\/span>:<\/span> Always<\/span>\r\n        resources<\/span>:<\/span>\r\n          limits<\/span>:<\/span>\r\n            cpu<\/span>:<\/span> 1000m<\/span>\r\n            memory<\/span>:<\/span> 512Mi<\/span>\r\n        tty<\/span>:<\/span> true<\/span>\r\n      dnsConfig<\/span>:<\/span>\r\n        options<\/span>:<\/span>\r\n        -<\/span> name<\/span>:<\/span> ndots<\/span>\r\n          value<\/span>:<\/span> \"<\/span>1\"<\/span>\r\n<\/code><\/pre>\n
Docker\u74b0\u5883\u4e0b\u3067\u306e Dockerfile \u3068 docker-compose.yml \u306e\u904e\u53bb\u60c5\u5831<\/h2>\n
Producer\/Comsumer \u306e Dockerfile \u3068 docker-compose.yaml \u306b\u3064\u3044\u3066\u306f\u3053\u3061\u3089\u3092\u53c2\u7167\u304f\u3060\u3055\u3044\u3002
\nzookeeper \u3068 broker \u3068 ksql-server\/ksql-cli \u306e docker-compose.yaml \u306b\u3064\u3044\u3066\u306f\u3053\u3061\u3089\u3092\u53c2\u7167\u304f\u3060\u3055\u3044\u3002<\/p>\n
Harbor \u3078 Producer\/Comsumer \u306e Docker Image \u306e Push<\/h2>\n
Docker Image \u3092\u4f5c\u6210\u3057\u3001\u30b3\u30f3\u30c6\u30ca\u30ec\u30b8\u30b9\u30c8\u30ea\uff08Harbor\uff09\u306b Push \u3057\u307e\u3059\u3002<\/p>\n
$ docker image build -t python-iot:3.8.3-slim .\r\n$ docker image ls                            \r\nREPOSITORY        TAG            IMAGE ID       CREATED          SIZE\r\npython-iot        3.8.3-slim     5966a0f42ed5   29 minutes ago   331MB\r\n\r\n$ docker tag python-iot:3.8.3-slim harbor.nwdiamanti.local\/nw-kafka\/python-iot:1.0.0\r\n$ docker login harbor.nwdiamanti.local\r\n$ docker push harbor.nwdiamanti.local\/nw-kafka\/python-iot:1.0.0\r\n<\/code><\/pre>\n
\u5404Pod \u306e\u4f5c\u6210<\/h2>\n
\uff14\u3064\u306e\u30de\u30cb\u30d5\u30a7\u30b9\u30c8\u304b\u3089\u5404\u7a2ePod\u306e\u8d77\u52d5\u3068\u78ba\u8a8d<\/p>\n
$ kubectl apply -f python-iot-dev.yaml \r\ndeployment.apps\/iot created\r\n\r\n$ kubectl apply -f zookeeper-v1.yaml \r\n\u3000service\/kafka-zookeeper created\r\n\u3000deployment.apps\/kafka-zookeeper created\r\n\r\n$ kubectl apply -f broker-v1.yaml \r\n\u3000service\/kafka-broker created\r\n\u3000deployment.apps\/kafka-broker created\r\n\r\n$ kubectl apply -f ksql-v1.yaml \r\n  service\/kafka-ksql-server created\r\n  deployment.apps\/kafka-ksql-server created\r\n  deployment.apps\/kafka-ksql-cli created\r\n\r\n$ kubectl get pod -n spektra-demo-tenant01-project-nw-kafka -o wide\r\n   NAME                                READY   STATUS    RESTARTS   AGE\r\n   iot-b948b544-82nhj                  1\/1     Running   0          12h   <--- Producer\u4f7f\u7528\r\n   iot-b948b544-whkbn                  1\/1     Running   0          12h   <--- Consumer\u4f7f\u7528\r\n   kafka-broker-f79866747-vp6tc        1\/1     Running   0          12h\r\n   kafka-ksql-cli-64565d78db-fx6xz     1\/1     Running   0          12h\r\n   kafka-ksql-server-f8766c6f5-mtgqz   1\/1     Running   0          12h\r\n   kafka-zookeeper-6bf5c4c6bf-88zrz    1\/1     Running   0          12h\r\n<\/code><\/pre>\n
\u5b9f\u884c\u7d50\u679c<\/h2>\n
\u3082\u3061\u308d\u3093\u3001\u3053\u308c \u3068\u540c\u3058\u7d50\u679c\u3068\u306a\u308a\u307e\u3057\u305f\u3002<\/p>\n
\u6700\u5f8c\u306b<\/h2>\n
\u30a2\u30d7\u30ea\u5c4b\u3055\u3093\u304c\u3001kubectl\u7b49\u306e\u30b3\u30de\u30f3\u30c9\u3092\u53e9\u304d\u3001Kubernetes\u74b0\u5883\u4e0b\u3067\u306e\u30b3\u30f3\u30c6\u30ca\u30d7\u30ed\u30b0\u30e9\u30e0\u306e\u52d5\u304d\u307e\u3067\u3092\u4f53\u611f\u3057\u307e\u3057\u305f\u304c\u3001\u3084\u306f\u308a\u3001\u30a2\u30d7\u30ea\u5c4b\u304c\u672c\u696d\u306b\u6ce8\u529b\u3059\u308b\u305f\u3081\u306b\u306f\u3001CI\/CD\u306e\u4ed5\u7d44\u306e\u5c0e\u5165\u304c\u5fc5\u8981\u3060\u3068\u75db\u611f\u3057\u305f\u3002<\/p>\n
\u53c2\u8003\u60c5\u5831<\/h2>\n
\u4ee5\u4e0b\u306e\u60c5\u5831\u3092\u53c2\u8003\u306b\u3055\u305b\u3066\u3044\u305f\u3060\u304d\u307e\u3057\u305f\u3002\u611f\u8b1d\u7533\u3057\u4e0a\u3052\u307e\u3059\u3002
\nKubernetes \u307e\u3068\u3081
\nKubernetes \u306eService\u306b\u3064\u3044\u3066\u307e\u3068\u3081\u3066\u307f\u305f
\n\u30b3\u30f3\u30c6\u30ca\u30ea\u30dd\u30b8\u30c8\u30ea Harbor in kubernetes \u306e\u691c\u8a3c
\nKubernetes \uff1akubectl \u30b3\u30de\u30f3\u30c9\u4e00\u89a7
\nKubernetes \u306e\u30dd\u30c3\u30c9\u304c\u8d77\u52d5\u3057\u306a\u3044\u539f\u56e0\u3068\u5bfe\u7b56
\nKubernetes 1.10 Cluster\u5185DNS\u306e\u6319\u52d5\u78ba\u8a8d<\/p>\n","protected":false},"excerpt":{"rendered":"
\u6982\u8981 Kafka\u306b\u9b45\u305b\u3089\u308c\u3066\u3001\u3068\u308a\u3042\u3048\u305a\u624b\u5143\u306e\u30de\u30b7\u30f3\u3067\u52d5\u304b\u3057\u3066\u307f\u307e\u3057\u3087\u3046\u304b\u3001\u3001\u3001\u3068\u3001\u30a4\u30f3\u30d5\u30e9\u3057\u304b\u77e5\u3089\u306a\u3044SE\u304c […]<\/p>\n","protected":false},"author":4,"featured_media":0,"comment_status":"closed","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[],"class_list":["post-46749","post","type-post","status-publish","format-standard","hentry","category-uncategorized"],"yoast_head":"\n- 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\/46749-2\/\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:description\" content=\"\u6982\u8981 Kafka\u306b\u9b45\u305b\u3089\u308c\u3066\u3001\u3068\u308a\u3042\u3048\u305a\u624b\u5143\u306e\u30de\u30b7\u30f3\u3067\u52d5\u304b\u3057\u3066\u307f\u307e\u3057\u3087\u3046\u304b\u3001\u3001\u3001\u3068\u3001\u30a4\u30f3\u30d5\u30e9\u3057\u304b\u77e5\u3089\u306a\u3044SE\u304c […]\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.silicloud.com\/zh\/blog\/46749-2\/\" \/>\n<meta property=\"og:site_name\" content=\"Blog - Silicon Cloud\" \/>\n<meta property=\"article:published_time\" content=\"2023-07-19T00:37:58+00:00\" \/>\n<meta property=\"article:modified_time\" content=\"2024-04-29T21:53:01+00:00\" \/>\n<meta property=\"og:image\" content=\"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d663937434c4406d098f2\/2-0.png\" \/>\n<meta name=\"author\" content=\"\u79d1, \u96c5\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"\u4f5c\u8005\" \/>\n\t<meta name=\"twitter:data1\" content=\"\u79d1, \u96c5\" \/>\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\/46749-2\/\",\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/46749-2\/\",\"name\":\"- Blog - Silicon Cloud\",\"isPartOf\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#website\"},\"datePublished\":\"2023-07-19T00:37:58+00:00\",\"dateModified\":\"2024-04-29T21:53:01+00:00\",\"author\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/41e222757cdd2a3365361328bd79970a\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.silicloud.com\/zh\/blog\/46749-2\/\"]}]},{\"@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\/41e222757cdd2a3365361328bd79970a\",\"name\":\"\u79d1, \u96c5\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/secure.gravatar.com\/avatar\/1b2d3e00a7df03689797ebd4af8c5827ba5af936849a71050ec331f4cf902c5d?s=96&d=mm&r=g\",\"contentUrl\":\"https:\/\/secure.gravatar.com\/avatar\/1b2d3e00a7df03689797ebd4af8c5827ba5af936849a71050ec331f4cf902c5d?s=96&d=mm&r=g\",\"caption\":\"\u79d1, \u96c5\"},\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/author\/keya\/\"},{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/46749-2\/#local-main-organization-logo\",\"url\":\"\",\"contentUrl\":\"\",\"caption\":\"Blog - Silicon Cloud\"}]}<\/script>\n<!-- \/ Yoast SEO Premium plugin. -->","yoast_head_json":{"title":"- 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\/46749-2\/","og_locale":"zh_CN","og_type":"article","og_description":"\u6982\u8981 Kafka\u306b\u9b45\u305b\u3089\u308c\u3066\u3001\u3068\u308a\u3042\u3048\u305a\u624b\u5143\u306e\u30de\u30b7\u30f3\u3067\u52d5\u304b\u3057\u3066\u307f\u307e\u3057\u3087\u3046\u304b\u3001\u3001\u3001\u3068\u3001\u30a4\u30f3\u30d5\u30e9\u3057\u304b\u77e5\u3089\u306a\u3044SE\u304c […]","og_url":"https:\/\/www.silicloud.com\/zh\/blog\/46749-2\/","og_site_name":"Blog - Silicon Cloud","article_published_time":"2023-07-19T00:37:58+00:00","article_modified_time":"2024-04-29T21:53:01+00:00","og_image":[{"url":"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d663937434c4406d098f2\/2-0.png"}],"author":"\u79d1, \u96c5","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"\u79d1, \u96c5","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"4 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.silicloud.com\/zh\/blog\/46749-2\/","url":"https:\/\/www.silicloud.com\/zh\/blog\/46749-2\/","name":"- Blog - Silicon Cloud","isPartOf":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/#website"},"datePublished":"2023-07-19T00:37:58+00:00","dateModified":"2024-04-29T21:53:01+00:00","author":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/41e222757cdd2a3365361328bd79970a"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.silicloud.com\/zh\/blog\/46749-2\/"]}]},{"@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\/41e222757cdd2a3365361328bd79970a","name":"\u79d1, \u96c5","image":{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/image\/","url":"https:\/\/secure.gravatar.com\/avatar\/1b2d3e00a7df03689797ebd4af8c5827ba5af936849a71050ec331f4cf902c5d?s=96&d=mm&r=g","contentUrl":"https:\/\/secure.gravatar.com\/avatar\/1b2d3e00a7df03689797ebd4af8c5827ba5af936849a71050ec331f4cf902c5d?s=96&d=mm&r=g","caption":"\u79d1, \u96c5"},"url":"https:\/\/www.silicloud.com\/zh\/blog\/author\/keya\/"},{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.silicloud.com\/zh\/blog\/46749-2\/#local-main-organization-logo","url":"","contentUrl":"","caption":"Blog - Silicon Cloud"}]}},"_links":{"self":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/46749","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\/4"}],"replies":[{"embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/comments?post=46749"}],"version-history":[{"count":2,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/46749\/revisions"}],"predecessor-version":[{"id":90093,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/46749\/revisions\/90093"}],"wp:attachment":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/media?parent=46749"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/categories?post=46749"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/tags?post=46749"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}