kafka和zookeeper的k8容器启动问题

iibxawm4  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(748)

我正试图创建一个与k8Zookeeper和Kafka Spring 开机生产者和消费者，但不能设置k8部署失败，不知道这里配置什么是错误的，因为同样的事情是在docker为我工作
我使用下面的文件在本地docker desktop kubectl apply-f$（pwd）/kubernates/sample.yml中创建服务和部署
以及我在上一次添加的部署时遇到的错误

  1. apiVersion: v1
  2. kind: Service
  3. metadata:
  4.   name: zookeeper
  5.   labels:
  6.     app: zookeeper
  7. spec:
  8.   ports:
  9.     - name: client
  10.       port: 2181
  11.       protocol: TCP
  12.     - name: follower
  13.       port: 2888
  14.       protocol: TCP
  15.     - name: leader
  16.       port: 3888
  17.       protocol: TCP
  18.   selector:
  19.     app: zookeeper
  20. ---
  21. kind: Deployment
  22. apiVersion: apps/v1
  23. metadata:
  24.   name: zookeeper
  25. spec:
  26.   selector:
  27.     matchLabels:
  28.       app: zookeeper
  29.   template:
  30.     metadata:
  31.       labels:
  32.         app: zookeeper
  33.     spec:
  34.       containers:
  35.         - name: zoo1
  36.           image: digitalwonderland/zookeeper
  37.           ports:
  38.             - containerPort: 2181
  39.           env:
  40.             - name: ZOOKEEPER_ID
  41.               value: "1"
  42.             - name: ZOOKEEPER_SERVER_1
  43.               value: zookeeper
  44. ---
  45. apiVersion: v1
  46. kind: Service
  47. metadata:
  48.   name: kafka
  49.   labels:
  50.     name: kafka
  51. spec:
  52.   ports:
  53.     - port: 9092
  54.       name: kafka-port
  55.       protocol: TCP
  56.   selector:
  57.     app: kafka
  58.     id: "0"
  59. ---
  60. kind: Deployment
  61. apiVersion: apps/v1
  62. metadata:
  63.   name: kafka
  64. spec:
  65.   selector:
  66.     matchLabels:
  67.       app: kafka
  68.   template:
  69.     metadata:
  70.       labels:
  71.         app: kafka
  72.         id: "0"
  73.     spec:
  74.       containers:
  75.         - name: kafka
  76.           image: wurstmeister/kafka
  77.           ports:
  78.             - containerPort: 9092
  79.           env:
  80.             - name: KAFKA_ADVERTISED_PORT
  81.               value: "9092"
  82.             - name: KAFKA_ADVERTISED_HOST_NAME
  83.               value: kafka
  84.             - name: KAFKA_ZOOKEEPER_CONNECT
  85.               value: zookeeper:2181
  86.             - name: KAFKA_BROKER_ID
  87.               value: "0"
  88.             - name: KAFKA_CREATE_TOPICS
  89.               value: sample.topic:1:1
  90. ---
  91. kind: Deployment
  92. apiVersion: apps/v1
  93. metadata:
  94.   name: kafka-cat
  95. spec:
  96.   selector:
  97.     matchLabels:
  98.       app: kafka-cat
  99.   template:
  100.     metadata:
  101.       labels:
  102.         app: kafka-cat
  103.     spec:
  104.       containers:
  105.         - name: kafka-cat
  106.           image: confluentinc/cp-kafkacat
  107.           command: ["/bin/sh"]
  108.           args: ["-c", "trap : TERM INT; sleep infinity & wait"]**

容器中出现异常

  2. **[2020-08-03 18:47:49,724] ERROR Exiting Kafka due to fatal exception (kafka.Kafka$)
  4. org.apache.kafka.common.config.ConfigException: Invalid value tcp://10.103.92.112:9092 for configuration port: Not a number of type INT
  5.     at org.apache.kafka.common.config.ConfigDef.parseType(ConfigDef.java:726)
  6.     at org.apache.kafka.common.config.ConfigDef.parseValue(ConfigDef.java:474)
  7.     at org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:467)
  8.     at org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:108)
  9.     at org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:142)
  10.     at kafka.server.KafkaConfig.<init>(KafkaConfig.scala:1235)
  11.     at kafka.server.KafkaConfig.<init>(KafkaConfig.scala:1238)
  12.     at kafka.server.KafkaConfig$.fromProps(KafkaConfig.scala:1218)
  13.     at kafka.server.KafkaServerStartable$.fromProps(KafkaServerStartable.scala:34)
  14.     at kafka.server.KafkaServerStartable$.fromProps(KafkaServerStartable.scala:29)
  15.     at kafka.Kafka$.main(Kafka.scala:68)
  16.     at kafka.Kafka.main(Kafka.scala)
apache-kafkadocker-desktop

1条答案

按热度按时间
46scxncf

46scxncf1#

最后我用Kafka的不同名字解决了这个问题

  1. apiVersion: v1
  2. kind: Service
  3. metadata:
  4.   name: zookeeper
  5.   labels:
  6.     app: zookeeper
  7. spec:
  8.   selector:
  9.     app: zookeeper
  10.   ports:
  11.     - name: client
  12.       port: 2181
  13.       protocol: TCP
  14.     - name: follower
  15.       port: 2888
  16.       protocol: TCP
  17.     - name: leader
  18.       port: 3888
  19.       protocol: TCP
  21. ---
  22. kind: Deployment
  23. apiVersion: apps/v1
  24. metadata:
  25.   name: zookeeper
  26. spec:
  27.   selector:
  28.     matchLabels:
  29.       app: zookeeper
  30.   template:
  31.     metadata:
  32.       labels:
  33.         app: zookeeper
  34.     spec:
  35.       containers:
  36.         - name: zookeeper
  37.           image: digitalwonderland/zookeeper
  38.           ports:
  39.             - containerPort: 2181
  40.           env:
  41.             - name: ZOOKEEPER_ID
  42.               value: "1"
  43.             - name: ZOOKEEPER_SERVER_1
  44.               value: zookeeper
  46. ---
  47. apiVersion: v1
  48. kind: Service
  49. metadata:
  50.   name: kafka-service0
  51.   labels:
  52.     name: kafka
  53. spec:
  54.   ports:
  55.     - port: 9092
  56.       name: kafka-port
  57.       protocol: TCP
  58.   selector:
  59.     app: kafka
  60.     id: "0"
  62. ---
  64. kind: Deployment
  65. apiVersion: apps/v1
  66. metadata:
  67.   name: kafka-broker0
  68. spec:
  69.   selector:
  70.     matchLabels:
  71.       app: kafka
  72.   template:
  73.     metadata:
  74.       labels:
  75.         app: kafka
  76.         id: "0"
  77.     spec:
  78.       containers:
  79.         - name: kafka
  80.           image: wurstmeister/kafka
  81.           ports:
  82.             - containerPort: 9092
  83.           env:
  84.             - name: KAFKA_ADVERTISED_PORT
  85.               valueFrom:
  86.                 configMapKeyRef:
  87.                   name: application-conf
  88.                   key: kafka_ad_port
  89.             - name: KAFKA_ZOOKEEPER_CONNECT
  90.               valueFrom:
  91.                 configMapKeyRef:
  92.                   name: application-conf
  93.                   key: zk_url
  94.             - name: KAFKA_CREATE_TOPICS
  95.               valueFrom:
  96.                 configMapKeyRef:
  97.                   name: application-conf
  98.                   key: kafka_topic
  99.             - name: KAFKA_BROKER_ID
  100.               value: "0"
  101.             - name: KAFKA_ADVERTISED_HOST_NAME
  102.               value: kafka-service0
展开查看全部
赞(0）分享  回复(0）举报  2021-06-04
我来回答

相关问题

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新问答

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com