package 循环 jsp date jqgrid oracle删除表字段 linux获取当前时间 centos查看python版本 python多线程 python3入门 python搭建网站 java泛型 java入门教程 java开发接口 java结构 java怎么安装 java数组输出 java结束线程 java怎么获取当前时间 linux镜像安装 python源码下载 tftpd64 反转颜色 电子书制作软件 go2lan medcalc js字符转数字 备份数据的软件 万能低格工具还原u盘 无主之地2联机超时 羽化快捷键 vs2017密钥 3dmax材质编辑器 excel转csv 小程序图片上传 安卓人脸识别 樱牛在哪 XR基带 cdr群组快捷键 生成海报
当前位置: 首页 > 学习教程  > 编程语言

Kafka:exception is org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not

2020/7/24 10:11:40 文章标签:

错误:

Failed to send; nested exception is org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition.

找不到推送消息服务器的所在分区,那估计就是kafka挂掉了

1.kafka的几个概念:

producer:生产者。
consumer:消费者。
topic: 消息以topic为类别记录,每一类的消息称之为一个主题(Topic)。为了提高吞吐量,每个消息主题又会有多个分区
broker:以集群的方式运行,可以由一个或多个服务组成,每个服务叫做一个broker;消费者可以订阅一个或多个主题(topic),并从Broker拉数据,从而消费这些已发布的消息。

每个消息(也叫作record记录,也被称为消息)是由一个key,一个value和时间戳构成。

一个broker 相当于一个kafka 服务实例,一个服务实例里面有多个topic 主题,

一个主题下面有多个分区partition,


本文链接: http://www.dtmao.cc/news_show_50211.shtml

附件下载

相关教程

    暂无相关的数据...

共有条评论 网友评论

验证码: 看不清楚?