kafka的生产者如何把消息发送到指定分区里

发送分区设置

默认配置

The default partitioning strategy:

If a partition is specified in the record, use it

If no partition is specified but a key is present choose a partition based on a hash of the key

If no partition or key is present choose a partition in a round-robin fashion

org.apache.kafka.clients.producer.internals.DefaultPartitioner：

如果在发消息的时候指定了分区，则消息投递到指定的分区
如果没有指定分区，但是消息的key不为空，则基于key的哈希值来选择一个分区
如果既没有指定分区，且消息的key也是空，则用轮询的方式选择一个分区

指定分区

指定分区的时候。会发送到具体分区里面

如何发送

1、在发送消息前，无限for循环去kafka集群里面拿分区信息

2、拿到了分区信息后，进行匹配发送到哪个分区，然后唤醒消费者去发送消息

kafka的生产者如何把消息发送到指定分区里相关推荐

将鼠标消息发送给指定的父控件_勾子
以下类通过挂载勾子原理,实现将子控件鼠标消息发送给父控件. 调用: MousePreview mp=new MousePreview(pControl); //pControl为父控件 //启用勾子 ...
java kafka producer_KafkaProducer未成功将消息发送到队列中
我在我的Windows PC上构建了一个小测试环境并写下以下代码来测试kafka(使用org.apache.kafka中的kafka_2.10:0.9.0.1) . package iii.funct ...
rocketmq 消息自定义_RocketMQ的消息发送及消费
RocketMQ消息支持的模式: 消息支持的模式分为三种:NormalProducer(普通同步),消息异步发送,OneWay. 消息同步发送: 普通消息的发送和接收在前面已经演示过了,在前面的案例中 ...
kafka 中如何保证数据消息不丢失
背景前几天,去两家公司面试,面试的过程中, 两家公司的面试官都给我提了如标题这样的一个问题.因为之前对kafka有一些了解,但是没有对这个的问题做过总结,现场就凭着记忆的进行了回答,面试官也表示这个 ...
Rocket之消息发送
涉及角色生产者组:一个逻辑概念,在使用生产者实例的时候需要指定一个组名.一个生产者组可以生产多个Topic的消息. 生产者实例:一个生产者组部署了多个进程,每个进程都可以称为一个生产者实例. Top ...
Java实现消息发送
消息发送和接收演示接下来我们使用Java代码来演示消息的发送和接收 <dependency><groupId>org.apache.rocketmq</groupId& ...
【kafka系列】kafka之生产者发送消息实践
目录一.准备工作二.终端命令生产者命令消费者命令三.Java实践搭建项目异步发送-无回调异步发送-有回调同步发送一.准备工作进入实战之前先熟悉一下topic的相关命令,使用终端命 ...
Kafka生产者——消息发送流程，同步、异步发送API
生产者消息发送流程发送原理 Kafka的Producer发送消息采用的是异步发送的方式. 在消息发送的过程中,涉及到了两个线程:main线程和Sender线程,以及一个线程共享变量:RecordAc ...
Kafka 生产者消息发送流程
1. 数据生产流程解析 Producer创建时,会创建一个Sender线程并设置为守护线程. 生产消息时,内部其实是异步流程;生产的消息先经过拦截器->序列化器->分区器,然后将消息缓存在 ...

kafka的生产者如何把消息发送到指定分区里

发送分区设置

默认配置

指定分区

如何发送

kafka的生产者如何把消息发送到指定分区里相关推荐

最新文章

热门文章