Pod向Strimzi发布KafkaJ消息时总是崩溃

Question

这是我的基于KafkaJs的publisher客户端。我创建了一个容器镜像，并向Pod代理提交了Strimzi YAML。

const { Kafka } = require('kafkajs')

async function clients() {
const kafka = new Kafka({
  clientId: 'my-app',
  brokers: ['test-kafka-bootstrap.strimzi.svc.cluster.local:9092']
})

const producer = kafka.producer()

await producer.connect()
await producer.send({
  topic: 'clients',
  messages: [
    { value: 'Hello KafkaJS user!' },
  ],
})

await producer.disconnect()
}

clients()

我的Dockerfile。

FROM node:14 as build_app

WORKDIR /

WORKDIR /app
COPY app .
COPY package.json .
COPY package-lock.json .
RUN npm i
CMD ["node", "index.js"]

我的pod YAML。

apiVersion: v1
kind: Pod
metadata:
  name: clients
spec:
  containers:
  - name: clients
    image: ghcr.io/org/clients:v0.0.0
    imagePullPolicy: Always

Pod一直在崩溃，kubectl logs没有显示任何东西--它是空的。kubectl describe也没有透露任何信息。

我遗漏了什么？

Answer 1

日志不显示任何内容，因为1)您的代码没有日志输出2)您的代码只发送一条记录，然后停止，因此容器干净地退出；它不是一个长时间运行的服务。使用简单的docker run命令也会遇到同样的问题。

如果你想要一个长时间运行的服务，你需要将你的代码包装在一个k8s服务中(NextJS、Express、Hapi等)，然后为web服务添加一个健康检查探针。

Answer 2

您可以在睡眠模式下启动pod，并在那里进行调试，使用下面的yaml

apiVersion: v1
kind: Pod
metadata:
  name: clients
spec:
  containers:
  - name: clients
    image: ghcr.io/org/clients:v0.0.0
    imagePullPolicy: Always
    command: ["sleep" , "100000000"]

现在执行到pod中

kubectl exec -it <pod> -- bash

现在执行

node index.js