没有合适的资源?快使用搜索试试~ 我知道了~
首页kafka中文文档producer配置参数
资源详情
资源评论
资源推荐

名称
描述
类型
默认值
可值
重要性
bootstrap.servers
⽤于建⽴初始
化到kafka服
务器连接的主
机/端⼜的列
表。客记端将
使⽤所有服务
器,不论哪些
服务器在这⾥
是⽤来引导
的。这个列表
只影响⽤来发
现所有服务器
集合的初始化
主机。这个列
表应当是以下
形式
host1:port1,ho
st2:port2,....因
为这些服务器
只⽤来初始化
连接到发现所
有的集群成员
(有可能动态
改变),这个
列表没有必要
包括所有的服
务器集合(你
想要多于⼀
个,尽管,以
防⼀台服务器
已经挂了)。
列表
⾼
key.serializer
实现
Serializer
接⼜的系列化
类,⽤于键的
系列化。
类
⾼
value.serializer
实现
Serializer
接⼜的系列化
类,⽤于值的
系列化。
类
⾼
名称

acks
⽣产者要求领
导者在考虑⼀
个请求完成之
前收接收的确
认的数量。这
个控制被发送
记录发送的持
久性。随后的
设置是被允许
的:acks=0如
果设为0那么
⽣产者不会等
待从服务器来
的任何的确
认。记录会马
上被添加到套
接字缓冲⾥然
后发送。在这
种情况下⽆法
保证服务器收
到这个记录,
并且重试配置
将不会⽣效
(因为客户端
不知道任何失
败)。每条记
录的返回的偏
移量通常被设
为-1 。acks=1
这将意味着领
导者将把记录
写到它本地的
⽇志中但不会
等待从所有的
跟随者那得到
确认就进⾏响
应。在这种情
况下有可能在
确认记录之后
领导者马上失
败
字符
1
[all, -1, 0, 1]
⾼
描述
类型
默认值
可值
重要性
名称

但在跟随者复
制它之前记录
将会丢失。
acks=all这意
味着领导者将
等待所有的但
在同步的副本
的集合来确认
记录。这保证
了记录不会被
丢失并⾄少有
⼀个正在同步
的副本保持存
活。这是最⾼
的可⽤性保
证。这与设置
为acks=-1的
作⽤是相同
的。
描述
类型
默认值
可值
重要性
名称

buffer.memory
⽣产者可以⽤
来缓冲等待发
送到服务器的
记录的总内存
字节数。如果
记录发送的速
度⽐它们能够
被发送到服务
器的速度快那
么⽣产者会因
为
max.block.ms
被阻塞,在这
个之后它会抛
出⼀个异常。
这个设置应⼤
体上与⽣产者
将要使⽤的总
内存⼀致,但
不是强硬的约
束,因为不⽣
产⽤的所有内
存都⽤于缓
冲。⼀些额外
的内存将⽤作
压缩(如果压
缩被启⽤)也
是⽤于快速的
请求。
长整
型
33554432
[0,...]
⾼
描述
类型
默认值
可值
重要性
名称

compression.type
⽣产者创建的
所有数据的压
缩类型。默认
情况是⽆。可
⽤的值为
none, gzip,
snappy, 或
lz4 。压缩是
全批次的数
据,因此批处
理的效果也会
影响压缩⽐
(更多的批处
理意味着更好
的压缩)。
字符
none
⾼
描述
类型
默认值
可值
重要性
名称
剩余20页未读,继续阅读


















安全验证
文档复制为VIP权益,开通VIP直接复制

评论0