KAFKA中生产者和分区的问题

学习KAFKA时遇到的问题

生产者发送消息时，可以指定分区，是不是就意味着：有的消息只发给了某个分区，其他分区没有这个消息？

写回答
好问题 0 提建议
追加酬金
关注问题
分享
邀请回答
编辑收藏删除
收藏举报

1条回答默认最新

关注

码龄粉丝数原力等级 --

被采纳

被点赞

采纳率
爱coding的同学 2023-01-06 12:27
关注
是的。如果有副本的话，副本分区也有这个消息。

本回答被题主选为最佳回答 , 对您是否有帮助呢?

解决 1
无用
评论打赏
分享
举报

评论

按下Enter换行，Ctrl+Enter发表内容

报告相同问题？

关注问题

KAFKA中生产者和分区的问题 kafka
2023-01-06 12:17

回答 1 已采纳是的。如果有副本的话，副本分区也有这个消息。
这个kafka在Sparkstreaming生产者出问题 kafka spark
2023-01-23 19:40

回答 2 已采纳看起来你好像少这个jar ： kafka-clients，查找一下项目里引用了没有另外就是需要你check一下你代码里是否使用了 StringDeserializer 代替了 StringSer
kafka可以生产无法消费的问题 java kafka
2022-06-11 10:41

回答 1 已采纳给你个例子，是可以收发的。验证通过再和你的对比一下，你应该哪里配错了。 springboot集成kafka、消息发送、消费使用_‘’小磊的博客-CSDN博客_spri
kafka生产者分区策略选择
2022-12-05 11:29

大宝and小宝的博客一般情况下选择默认分区器(DefaultPartitioner),无论是否高并发,如果极致追求数据平均分布,选择轮询分区器(RoundRobinPartitioner).纯粹的粘性分区策略(UniformStickyPartitioner)基本没有使用场景.高并发下不需要,...
【kafka】kafka消息生产者抛异常
2018-04-27 17:31

回答 2 已采纳 1, 先确认你的网络有没有问题 2，在向服务器发起连接后，在kafka的服务器配置中有zookeeper.connect=xx.xx.xx.xx：2181的配置这时候kafka会查找zookeep
pycharm中kafka错误问题 kafka python ubuntu 有问必答
2021-06-17 17:19

回答 10 已采纳 https://blog.csdn.net/qq_40407889/article/details/118028472 java的kafka操作的简单demo
Flume和kafka连接的问题 flume 大数据
2018-07-21 14:46

回答 1 已采纳 https://blog.csdn.net/weixin_40137479/article/details/79214312
【项目实战】Kafka 生产者写入分区的策略
2023-07-16 16:21

激流丶的博客 2. **随机分区策略**：Kafka生产者随机的将消息写入分区，有可能会造成消息的分布不均，所以这个策略基本上也很少用。 3. **按 key 分区策略**：Kafka生产者基于消息的键（key）进行哈希计算，然后将消息写入对应的...
一台机器可以即可以充当kafka消费者又充当kafka生产者吗？ java kafka
2022-01-10 15:46

回答 3 已采纳消费者和生产者与机器无关，这是不同的概念，消费者与生产者只是在Kafka中的角色，不同角色干不同的事情
kafka分区策略疑惑 java kafka
2022-12-20 23:32

回答 1 已采纳消息经过序列化之后就需要确定它发往的分区，如果消息ProducerRecord中指定了partition字段，那么就不需要分区器的作用，因为partition代表的就是所要发往的分区号。如果消息Pro
kafka消费者创建不了 java kafka linux
2022-08-23 10:01

回答 1 已采纳同一个消费组能同时消费的消费者数量和topic的分区数有关，估计是你的topic只有两个分区所以使用相同的groupid只有两个消费者在消费，加一个分区就好
Kafka生产者分区写入规则和副本机制
2021-03-31 11:32

大数据老人家i的博客文章目录生产者分区写入规则概述分类副本机制概述producer的ACKS参数参数分类 生产者分区写入规则概述 生产者写入消息到topic，Kafka将依据不同的规则将数据分配到不同的分区中，如果指定了分区数据就会写到指定...
sqoop和kettle可以实现oracle到kafka嘛 hbase sqoop 大数据
2022-08-08 17:40

回答 1 已采纳都可以抽Oracle写Kafka重点是你要怎么做数据抽取，增量变更捕获或者就是全量抽
Kafka生产者分区策略和数据可靠性保证
2020-02-04 19:57

小猴子豆芽菜的博客分区策略分区原因：方便集群扩展，每个Partition可以通过调整大小以适应它所在的机器，而一个 topic又可以由多个 Partition组成，因此整个集群就可以适应任意大小的数据。可以提高并发，分区之后就可以以...
大数据技术之Kafka——Kafka入门
2023-04-20 23:11

five小点心的博客传统定义：Kafka是一个分布式的基于发布/订阅模式的消息队列（Message Queue）主要应用于大数据实时处理领域。发布/订阅：消息的发布者不会将消息直接发送给特点的订阅者，而是将发布的消息分为不同的类别，订阅者只...
没有解决我的问题, 去提问

问题事件

关注

码龄粉丝数原力等级 --

被采纳

被点赞

采纳率
系统已结题 1月14日
关注

码龄粉丝数原力等级 --

被采纳

被点赞

采纳率
已采纳回答 1月6日
关注

码龄粉丝数原力等级 --

被采纳

被点赞

采纳率
创建了问题 1月6日

悬赏问题

¥30 这是哪个作者做的宝宝起名网站
¥60 版本过低apk如何修改可以兼容新的安卓系统
¥25 由IPR导致的DRIVER_POWER_STATE_FAILURE蓝屏
¥50 有数据，怎么建立模型求影响全要素生产率的因素
¥50 有数据，怎么用matlab求全要素生产率
¥15 TI的insta-spin例程
¥15 完成下列问题完成下列问题
¥15 C#算法问题, 不知道怎么处理这个数据的转换
¥15 YoloV5 第三方库的版本对照问题
¥15 请完成下列相关问题！

KAFKA中生产者和分区的问题

学习KAFKA时遇到的问题

生产者发送消息时，可以指定分区，是不是就意味着：有的消息只发给了某个分区，其他分区没有这个消息？

1条回答 默认 最新

问题事件

悬赏问题

1条回答默认最新