zoukankan      html  css  js  c++  java
  • 深入理解Kafka-学习笔记04-部分生产者客户端参数

    参数名称 默认值 参数释义
    bootstrap.servers ""

    指定连接kafka集群所需的broker地址清单

    可以只指定某一个broker,多个需用逗号隔开

    key.serializer "" 消息中key对应的序列化类
    value.serializer "" 消息中value对应的序列化类
    buffer.memory

    33554432(32MB)

    生产者客户端中用于缓存消息的缓冲区大小
    batch.size 16384(16KB) 用于指定ProducerBatch可以复用内存区域的大小
    client.id "" 用来设定KafkaProducer对应的客户端id
    max.block.ms 60000(60s) 用来控制KafkaProducer中send()方法和partitionsFor()方法的阻塞时间。当生产者的发送缓冲区己满,或者没有可用的元数据时,这些方法就会阻塞
    partitioner.class org.apache.kafka.clients.producer.intemals.DefaultPartitioner 用来指定分区器
    enable.idempotence false 是否开启幂等性功能
    interceptor.classes "" 用来设定生产者拦截器
    max.in.flight.requests.per.connection 5 限制每个连接(也就是客户端与Node之间的连接)最多缓存的请求数
    metadata.max.age.ms 300000(5分钟) 如果在这个时间内元数据没有更新的话会被强制更新
    transactional.id null 设置事务id,必须唯一
  • 相关阅读:
    体温单时间控件
    搭建Android 开发环境(精华)
    即时通讯
    车牌识别系统
    JSON 生成 C# Model
    Arduino 视频教程
    .Net主线程扑捉子线程中的异常
    用C#操作IIS创建虚拟目录和网站
    C#中简单的this与get的用法(string,decimal)
    c#读取Excel数据到Gridview
  • 原文地址:https://www.cnblogs.com/java-meng/p/15213408.html
Copyright © 2011-2022 走看看