文档章节

kafka Producer-ProducerRecord构造方法

k
 kdy1994
发布于 2017/03/20 13:30
字数 147
阅读 15
收藏 0

-- Topic (名字)

-- PartitionID ( 可选)

-- Key[( 可选 )

-- Value

-- ProducerRecord(topic, partition, key, value)

-- ProducerRecord(topic, key, value)

-- ProducerRecord(topic, value)

<1> 若指定Partition ID,则PR被发送至指定Partition

<2> 若未指定Partition ID,但指定了Key, PR会按照hasy(key)发送至对应Partition

<3> 若既未指定Partition ID也没指定Key,PR会按照round-robin模式发送到每个Partition

<4> 若同时指定了Partition ID和Key, PR只会发送到指定的Partition (Key不起作用,代码逻辑决定)

 

本文转载自:http://www.ithao123.cn/content-7147693.html

上一篇: 自旋锁
k
粉丝 3
博文 105
码字总数 43204
作品 0
昌平
程序员
私信 提问
Kafka分区分配计算(分区器Partitions)

KafkaProducer在调用send方法发送消息至broker的过程中,首先是经过拦截器Inteceptors处理,然后是经过序列化Serializer处理,之后就到了Partitions阶段,即分区分配计算阶段。在某些应用场景...

u013256816
2017/12/03
0
0
Kafka Producer拦截器

Kafka中的拦截器(Interceptor)是0.10.x.x版本引入的一个功能,一共有两种:Kafka Producer端的拦截器和Kafka Consumer端的拦截器。本篇主要讲述的是Kafka Producer端的拦截器,它主要用来对...

u013256816
2017/11/19
0
0
kafka 源码分析三 Producer

原文出处:刘正阳 Producer Producer是生产者的接口定义 常用的方法有 public Future send(ProducerRecord record);public Future send(ProducerRecord record, Callback callback);public ......

刘正阳
2018/05/20
0
0
kafka源码分析3 : Producer

原文出处:刘正阳 Producer Producer是生产者的接口定义 常用的方法有 public Future send(ProducerRecord record);public Future send(ProducerRecord record, Callback callback);public ......

刘正阳
2018/05/21
0
0
向kafka批量发送已存在的txt文件

需要利用kafka发送txt或log文件,有两种方式:1.自己写程序;2.利用kafka自带脚本。 自己写程序: package kafka.producer; import java.util.concurrent.ArrayBlockingQueue;import java.u...

-九天-
2018/01/10
2.8K
0

没有更多内容

加载失败,请刷新页面

加载更多

nginx学习笔记

中间件位于客户机/ 服务器的操作系统之上,管理计算机资源和网络通讯。 是连接两个独立应用程序或独立系统的软件。 web请求通过中间件可以直接调用操作系统,也可以经过中间件把请求分发到多...

码农实战
今天
5
0
Spring Security 实战干货:玩转自定义登录

1. 前言 前面的关于 Spring Security 相关的文章只是一个预热。为了接下来更好的实战,如果你错过了请从 Spring Security 实战系列 开始。安全访问的第一步就是认证(Authentication),认证...

码农小胖哥
今天
10
0
JAVA 实现雪花算法生成唯一订单号工具类

import lombok.SneakyThrows;import lombok.extern.slf4j.Slf4j;import java.util.Calendar;/** * Default distributed primary key generator. * * <p> * Use snowflake......

huangkejie
昨天
12
0
PhotoShop 色调:RGB/CMYK 颜色模式

一·、 RGB : 三原色:红绿蓝 1.通道:通道中的红绿蓝通道分别对应的是红绿蓝三种原色(RGB)的显示范围 1.差值模式能模拟三种原色叠加之后的效果 2.添加-颜色曲线:调整图像RGB颜色----R色增强...

东方墨天
昨天
11
1
将博客搬至CSDN

将博客搬至CSDN

算法与编程之美
昨天
13
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部