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,必须唯一
  • 相关阅读:
    MemoryCache
    Page.Cache
    webform运行时弹出JavaScript的alert窗口
    server.Transfer不工作
    Server.Transfer VS Response.Redirect – Simplified
    Code Pages
    Unicode, UTF, ASCII, ANSI format differences
    Character Encoding in .NET
    分布式之消息队列复习精讲
    Understand:高效代码静态分析神器详解(一)
  • 原文地址:https://www.cnblogs.com/java-meng/p/15213408.html
Copyright © 2011-2022 走看看