kafka集群节点重启后未被topic识别

9月前作者：Apex Predator 分类：Toy博客阅读(36) 违法举报

这篇具有很好参考价值的文章主要介绍了kafka集群节点重启后未被topic识别。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

1.案例

kafka集群的节点重启后，topic为apex的主题识别不到重启后的broker节点id，但是还能识别到副本集还在原来的broker节点上

在kafka manager上查看

kafka集群节点重启后未被topic识别

继续往下查看 kafka集群节点重启后未被topic识别

2.查看kafka日志报错原因

以下是两个不同的broker节点报错的报错日志

tail -f /etc/kafka/kafka/logs/kafkaServer.out

这是broker id为3的节点，这是topic识别不到的节点报错为下图的这个错误

Received INCONSISTENT_TOPIC_ID from the leader for partition test-1. This error may be returned transiently when the partition is being created or deleted, but it is not expected to persist

kafka集群节点重启后未被topic识别

这是broker id为1的节点，即topic还能识别到的节点报错为下图的这个错误

Received UNKNOWN_TOPIC_ID from the lea文章来源地址https://www.toymoban.com/news/detail-417689.html

到了这里，关于kafka集群节点重启后未被topic识别的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：如若内容造成侵权/违法违规/事实不符，请点击违法举报进行投诉反馈，一经查实，立即删除！

分享到：

领支付宝红包赞助服务器费用

Kafka三节点集群搭建

部署kafka集群最好是奇数台至少3台服务器，也可以在一台服务中部署三个kaf

2024年02月11日
浏览(32)
三节点kafka集群配置

1. 创建数据目录 2. 三台服务器创建myid文件,分别写入1 2 3 3. 配置hosts 4. 配置zookeeper配置文件 5. 启动zookeeper 查看日志kafka1 kafka2 kafka3 是服务器的主机名 6. 查看zookeeper状态查看第一台查看第二台查看第三台 1. 创建数据目录 2. hosts文件配置zookeeper时已配置 3.配置kafka配置文件

2024年02月03日
浏览(32)
kafka集群模拟单节点故障

这里通过kafka manage来展示节点宕机效果现在三台主机节点均正常 topic正常识别到三个broker leader也均匀分配到了三个broker上现在把节点id为0的主机模拟宕机可以通过以上两张图片看到每个topic现在只识别到了两个broker节点，broker id为0的节点已经被剔除掉了 isr列表的数据

2024年02月02日
浏览(26)
查看Kafka集群下所有的topic报错“Timed out waiting for a node assignment. Call: listTopics“

没有配置主机IP地址。取消掉 listeners 的注释，然后修改值为 listeners=PLAINTEXT://192.168.88.142:9092 ，其中 192.168.88.142 是当前服务器的IP地址。注意：Kafka集群中每台服务器上的 server.properties 配置文件都需要修改 listeners 配置项，都修改为自己对应服务器的IP地址。修改配置后，关

2024年02月16日
浏览(45)
集群重启后发现node1节点出现notready状态，问题排查及解决（kubelet与docker的cgroup驱动不同导致）

集群重启后发现node1节点出现notready状态排查： 1、查看服务器的物理环境 free -mh/df -h 2、查看内存是否溢出，磁盘空间是否够用，经查均在正常使用范围内； 3、top查看cpu使用状态，在可用范围内； 4、再查master组件scheduer，controller-manager，apiserver等都在正常运行； 5、查看n

2024年02月11日
浏览(46)
AppScan登录回放后未识别任何会话中模式

使用Appscan时，记录（推荐）录制后，在审查和验证页签下，点击“验证”遇到的一个阻碍：登录回放后未识别任何会话中模式。失败时的截图如下所示：解决办法是：不勾选 “会话ID”页签下的SESSION那一行。如下图所示：个人认为，原因可能是录制完登录步骤后。再次验

2024年02月12日
浏览(54)
[云原生案例2.1 ] Kubernetes的部署安装【单master集群架构 ---- （二进制安装部署）】节点部分

Minikube是一个工具，可以在本地快速运行一个单节点微型K8S，仅用于学习、预览K8S的一些特性使用。 Kubeadm也是一个工具，提供kubeadm init和kubeadm join，用于快速部署K8S集群，相对简单。生产首选，从官方下载发行版的二进制包，手动部署每个组件和自签TLS证书，组成K8S集群，

2024年02月05日
浏览(58)
kafka topic和topic权限操作

创建查询删除增加移除查询

2024年02月12日
浏览(36)
Kafka/Spark-01消费topic到写出到topic

消费者代码注意点 consumerConfigs是定义的可变的map的类型的，具体如下 consumerConfigs.put(ConsumerConfig.GROUP_ID_CONFIG , groupId)是为了不限制groupId特意写的传参是使用自带的kafka工具类createDirectStream方法去消费kafak 的数据，详细参数解释如下 Subscribe传参需要指定泛型，这边指定string，

2024年02月09日
浏览(33)
Kafka 清空Topic

测试环境某topic的数据格式发生了更改，需要将原有数据清空重新生产数据。还需检查当前kafka topic对应的分区副本（假定单分区单副本）大小，用于验证数据是否已删除。将过期时间设置为1秒直到该文件夹显示大小是20K即证明数据已清理同时需注意，数据清理时机受ser

2024年01月16日
浏览(42)