kafka - Ошибка при отправке сообщения в тему test-topic с ключом: null, значение: 17 байт с ошибкой - PullRequest
Новая
       67

kafka - Ошибка при отправке сообщения в тему test-topic с ключом: null, значение: 17 байт с ошибкой

0 голосов
/ 24 октября 2018

Я работаю над развертыванием Kafka / Zookeeper в Kubernetes, используя MINIKUBE.ниже приведен мой файл YAML: 

##################################
#   Setup Zookeeper Deployment
##################################

---
apiVersion: extensions/v1beta1
kind: Deployment
metadata:
  labels:
    app: zookeeper
  name: zookeeper
spec:
  replicas: 1
  template:
    metadata:
      labels:
        app: zookeeper
    spec:
      containers:
      - image: wurstmeister/zookeeper
       # imagePullPolicy: Always
        name: zookeeper
        ports:
        - containerPort: 2181


##################################
#   Setup Zookeeper Service
##################################

---
apiVersion: v1
kind: Service
metadata:
  labels:
    app: zookeeper-service
  name: zookeeper-service
spec:
  type: NodePort
  ports:
  - name: zookeeper-port
    port: 2181
    nodePort: 30181
    targetPort: 2181
  selector:
    app: zookeeper

---
##################################
  #   Setup Kafka service
##################################

apiVersion: v1
kind: Service
metadata:
  labels:
    app: kafka-service
  name: kafka-service
spec:
  type: NodePort
  ports:
  - name: kafka-port
    port: 9092
    nodePort: 30092
    targetPort: 9092
  selector:
    app: kafka

---
##################################
  #   Setup Kafka Broker Deployment
##################################

apiVersion: extensions/v1beta1
kind: Deployment
metadata:
  labels:
    app: kafka
  name: kafka
spec:
  replicas: 1
  template:
    metadata:
      labels:
        app: kafka
    spec:
      containers:
      - env:
        - name: KAFKA_ADVERTISED_HOST_NAME
          value: 192.168.99.100
        - name: KAFKA_ADVERTISED_PORT
          value: "30092"
        - name: KAFKA_BROKER_ID
          value: "1"
        - name: KAFKA_ZOOKEEPER_CONNECT
          value: 192.168.99.100:30181    
        - name: KAFKA_ADVERTISED_LISTENERS
          value: "PLAINTEXT://192.168.99.100:30092"
     #   - name: KAFKA_LISTENERS
     #     value: "PLAINTEXT://192.168.99.100:9092"
        - name: KAFKA_CREATE_TOPICS
          value: "vignesh-topic:1:1"
        - name: LOG4J_LOGGER_KAFKA_AUTHORIZER_LOGGER
          value: "DEBUG"
        image: wurstmeister/kafka
        #imagePullPolicy: Always
        name: kafka
        ports:
        - containerPort: 9092

Я успешно создал Deployment / Services на локальном компьютере Kubernetes, используя MINIKUBE, используя команду ниже. 

kubectl create -f kafka.yml

Я прошел внутри модулей Kafka и яЯ могу создать тему, используя следующую команду: 

./bin/kafka-topics.sh --create --zookeeper 192.168.99.100:30181 --replication-factor 1 --partitions 1 --topic test-topic

Но, когда я пытаюсь отправить сообщение в тему (test-topic), система выдает следующую ошибку:

error

Примечание

при запуске netstat -tunap , оба порта 30092и 30181 показывает установлено.

netstat

Я не знаю, что мне здесь не хватает.Пожалуйста, помогите мне двигаться вперед.

Спасибо и ценим вашу помощь.

1 Ответ

0 голосов
/ 05 декабря 2018

Спасибо @SoheilPourbafrani и @ cricket_007 за помощь!Я нашел обходной путь для вопроса, который я задал выше.

После того, как я запустил приведенную ниже команду в окне PowerShell, Кафка запустилась правильно и смогла связаться с ней также из Node Application и Kafka Tool. 

minikube ssh
sudo ip link set docker0 promisc on

Ссылки: Более новые версии Minikube не позволяют модулю использовать свои собственные службы

...