已婚教师骗奸女生,可米微博,学园默示录07
org.apache.kafka.common.errors.unknowntopicorpartitionexception: this server does not host this topic-partition
报错内容:分区数据不在
原因分析:producer向不存在的topic发送消息,用户可以检查topic是否存在 或者设置auto.create.topics.enable参数
warn error while fetching metadata with correlation id 0 : {test=leader_not_available} (org.apache.kafka.clients.networkclient
报错内容:leader不可用
原因分析:原因很多 topic正在被删除 正在进行leader选举 使用kafka-topics脚本检查leader信息
进而检查broker的存活情况 尝试重启解决
org.apache.kafka.common.errors.notleaderforpartitionexception: this server is not the leader for that topic-partition
报错内容:broker已经不是对应分区的leader了
原因分析:发生在leader变更时 当leader从一个broker切换到另一个broker时,要分析什么原因引起了leader的切换
org.apache.kafka.common.errors.timeoutexception: expiring 5 record(s) for test-0: 30040 ms has passe
报错内容:请求超时
原因分析:观察哪里抛出的 观察网络是否能通 如果可以通 可以考虑增加request.timeout.ms的值
warn async.defaulteventhandler: produce request with correlation id 92548048 failed due to [topicname,1]: org.apache.kafka.common.errors.recordtoolargeexception
报错内容:消息过大
原因分析:生产者端 消息处理不过来了 可以增加 request.timeout.ms 减少 batch.size
closing socket connection to/127,0,0,1.(kafka.network.processor)
报错内容:连接关闭
原因分析:如果javaapi producer版本高,想在客户端consumer启动低版本验证,会不停的报错
无法识别客户端消息。
java.util.concurrentmodificationexception: kafkaconsumer is not safe for multi-threaded access
报错内容:线程不安全
原因分析:kafka consumer是非线程安全的
[kafka-producer-network-thread | producer-1] o.apache.kafka.common.network.selector : [producer clientid=producer-1] connection with / disconnected
报错内容:网络异常
原因分析:网络连接中断 检查broker的网络情况
illegal_generation occurred while committing offsets for group
报错内容:无效的“代”
原因分析:consumer错过了 rebalance 原因是consumer花了大量时间处理数据。
需要适当减少 max.poll.records值 增加 max.poll.interval.ms 或者想办法增加消息处理的速度
未完待续~~~
更多实时计算,flink,kafka等相关技术博文,欢迎关注实时流式计算
如对本文有疑问,请在下面进行留言讨论,广大热心网友会与你互动!! 点击进行留言回复
去 HBase,Kylin on Parquet 性能表现如何?
如何找到Hive提交的SQL相对应的Yarn程序的applicationId
如何在 HBase Shell 命令行正常查看十六进制编码的中文?哈哈~
HBase Filter 过滤器之 Comparator 原理及源码学习
安装 Hadoop 2.9.1 on Windows 10 64 bit (最全步骤整理)
网友评论