無名

设置一年过期吧，够用了。

kubectl -n kubernetes-dashboard create token admin-user --duration=8760h

zk和kafka之间的认证失败了，检查下kafka和zk之间的认证。

可以了，谢谢大佬

最后少个&，我的错，我重新编辑了。

nohup ... > /dev/null 2>&1&

不好意思，是nohup bin/connect-distributed.sh config/connect-distributed.properties > /dev/null 2>&1，指令我刚才复制错了，但是为啥运行后没有显示信息出来一直卡在那

通过kafka-delete-record解决了这个问题，但是为什么没有触发自动老化还是没有思路

一般是docker的原因导致的。

一个可行的解决方案是重新启动 Docker 服务，然后重新运行 kubeadm reset：

sudo systemctl restart docker.service
sudo kubeadm reset

检查 docker 的日志：

journalctl -ul docker

https://github.com/kubernetes/kubernetes/issues/53533

你看下kafka集群的配置文件，是否设置了auto.create.topics.enable=false。

如果有，就设置为ture，当topic不存在，导致的，允许它自动创建。

或者你也可以手动创建topic：

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 4 --topic test

$ kubectl wait --for=condition=complete --timeout=600s job/myjob

Kubernetes(k8s)就是按照用户的期望的样子来运行部署应用程序。
赞！

大佬，非常高兴能看到你得文章

Kafka有5个核心API：

• Producer API 允许应用程序发送数据流到kafka集群中的topic。
• Consumer API 允许应用程序从kafka集群的topic中读取数据流。
• Streams API 允许从输入topic转换数据流到输出topic。
• Connect API 通过实现连接器（connector），不断地从一些源系统或应用程序中拉取数据到kafka，或从kafka提交数据到宿系统（sink system）或应用程序。
• Admin API 用于管理和检查topic，broker和其他Kafka对象。

具体可参考：kafka接口API