無名

感谢，你提醒了我，在这台服务器上有个监控kafka集群状态的组件，它会一直向kafka发送请求

我的意思是这个你不认识的地址，可能是从别的机器(192.168.66.211)连到kafka的时候，报的认证错误。

所以你先确认这个192.168.66.211的身份，是你公司的哪台机器属于谁的，可能是它一直连接kafka需要进行生产或者消费，而你加了认证之后，导致这台机器持续的连接重试，一直失败。

不是，就是配置完后，启动kafka 服务server.log就报这个

客户端连接的？

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

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

通过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