2

こんにちは、kubernets は初めてです。ローカルでの開発とテストに minikube シングル ノード クラスタを使用しています。

Host: Ubuntu 16.04 LTS.
Minikube: Virtual box running minikube cluster

私の要件は、ミニキューブにカフカとズーキーパーをデプロイする必要があり、メッセージの生成または消費に使用する必要があることです。このリンクをたどり、minikube に正常にデプロイしました。詳細は以下のとおりです。

$ kubectl get services
NAME            CLUSTER-IP   EXTERNAL-IP   PORT(S)                      AGE
kafka-service   10.0.0.15    <pending>     9092:30244/TCP               46m
kubernetes      10.0.0.1     <none>        443/TCP                      53m
zoo1            10.0.0.43    <none>        2181/TCP,2888/TCP,3888/TCP   50m
zoo2            10.0.0.226   <none>        2181/TCP,2888/TCP,3888/TCP   50m
zoo3            10.0.0.6     <none>        2181/TCP,2888/TCP,3888/TCP   50m

$ kubectl get pods
NAME                                      READY     STATUS    RESTARTS   AGE
kafka-deployment-3583985961-f2301         1/1       Running   0          48m
zookeeper-deployment-1-1598963595-vgx1l   1/1       Running   0          52m
zookeeper-deployment-2-2038841231-tdsff   1/1       Running   0          52m
zookeeper-deployment-3-2478718867-5vjcj   1/1       Running   0          52m

$ kubectl describe service kafka-service
Name:           kafka-service
Namespace:      default
Labels:         app=kafka
Annotations:    <none>
Selector:       app=kafka
Type:           LoadBalancer
IP:             10.0.0.15
Port:           kafka-port  9092/TCP
NodePort:       kafka-port  30244/TCP
Endpoints:      172.17.0.7:9092
Session Affinity:   None
Events:         <none>

KAFKA_ADVERTISED_HOST_NAME を minikube ip(192.168.99.100) に設定しました。メッセージプロデューサーの場合$cat textfile.log | kafkacat -b $(minikube ip):30244 -t mytopic、以下のメッセージを提供するメッセージを公開しないことを使用しています

% Auto-selecting Producer mode (use -P or -C to override)
% Delivery failed for message: Local: Message timed out

メッセージを公開して消費する方法を誰でも助けることができます。

4

4 に答える 4