27 lines
657 B
Properties
27 lines
657 B
Properties
#producer重试的次数设置
|
||
retries=0
|
||
|
||
#他的含义就是说一个Batch被创建之后，最多过多久，不管这个Batch有没有写满，都必须发送出去了
|
||
linger.ms=5
|
||
|
||
#如果在超时之前未收到响应，客户端将在必要时重新发送请求
|
||
request.timeout.ms=30000
|
||
|
||
#producer都是按照batch进行发送的,批次大小，默认:16384
|
||
batch.size=262144
|
||
|
||
#Producer端用于缓存消息的缓冲区大小
|
||
buffer.memory=67108864
|
||
|
||
#这个参数决定了每次发送给Kafka服务器请求的最大大小,默认1048576
|
||
max.request.size=5242880
|
||
|
||
#worker进程中向外发送消息的缓存大小
|
||
transfer_buffer_size=32
|
||
|
||
#executor线程的接收队列大小；需要为2的倍数
|
||
executor_receive_buffer_size=16384
|
||
|
||
#executor线程的发送队列大小；需要为2的倍数
|
||
executor_send_buffer_size=16384
|