页面树结构

版本比较

标识

  • 该行被添加。
  • 该行被删除。
  • 格式已经改变。

目录

面板
borderColor#00FFFF
borderStyledashed

原文链接 : http://kafka.apache.org/0101/documentation.html(修改该链接为官网对应的链接)

译文链接 : http://cwiki.apachecn.org/pages/viewpage.action?pageId=4882492(修改该链接为 ApacheCN 对应的译文链接)

贡献者 : @您的名字,ApacheCNApache中文网

目录 1 - 标题 2

丢雷楼某 、、、

下面是Java中Producer的配置:

名字描述类型默认值有效参数重要级别
bootstrap.servers

一个host/port 对列表,用来建立与Kafka 集群的初始化连接。Producer 客户端将会使用所有的服务器不论哪个服务器被指定为bootstrapping – 这个列表只会影响初始化hosts 用来发现在所有的Kafka 服务器。列表的格式应当为:host1:port1,host2:port2,... 。因为这些服务器只是用来初始化连接发现集群中所有的成员(这些成员也可能是动态变化的),所以这个列表不用包括所有的服务器(不过你可以配置不止一个,防止服务器当机)。

list  
key.serializerkey 的序列化类,该类实现了Serializer 接口。class  
value.serializervalue 的序列化类,该类实现了Serializer 接口。class  
acks

这个确认信息的值是producer 要求leader 考虑到一个请求完成之前确认的值。

这控制着发送记录的不可破坏性。允许以下设置:

  • acks=0 如果设置为0 ,producer 不会等待服务器发送的任何确认信息。记录会被
    立即加入到socket buffer 中并认为已被发送成功。在这种情况下,不能保证
    服务器已收到记录,重试配置retries 将不会生效(因为客户端通常不会知道任何
    故障)。每个记录返回的偏移将始终设置为-1。
string1[all, -1, 0, 1]
buffer.memory生产者可以用来缓冲等待发送到服务器的记录的内存总字节数。如果记录的发送速度能比传递到服务器的速度快,那么生产者将阻塞max.block.ms 毫秒,之后将抛出异常。long

33554432

(约9个多小时)

[0,...]
compression.type生产者生成的所有数据的压缩类型。默认值为none(即无压缩)。有效值为none,gzip,snappy或lz4。压缩是整个批次的数据,因此批量化的效果也将影响压缩比(更多的批次意味着更好的压缩)。stringnone 
retries设置大于零的值将导致客户端重新发送任何发送失败且可能存在临时错误的记录。请注意,这里的重试就是指客户端在接收到错误时重新发送记录。允许重试那些max.in.flight.requests.per.connection不是1的记录,这将潜在地更改记录的顺序,因为如果两个批次发送到单个分区,第一个失败并重试,但第二个成功,则在第二批中的记录可能先出现。int0

[0,...,

2147483647]

ssl.key.password密钥存储文件中的私钥的密码。 客户端是可选的。passwordnull 
ssl.keystore.location密钥存储文件的位置。 客户端是可选的,可以用于客户端的双向认证。stringnull 
ssl.keystore.password密钥存储文件的存储密码。 对客户端是可选的,只有在配置了ssl.keystore.location时才需要。passwordnull 
ssl.truststore.location信任库的位置。stringnull 
ssl.truststore.password信任库的密码。passwordnull 
batch.size

当多个记录发送到同一partition(分区)时,生产者将尝试将一批记录一起发送,减少请求次数。 这有助于客户端和服务器的性能。 此配置以字节为单位控制默认批量大小。

每次批量发送的大小不会超过此限制。

发送到brokers的请求将包含多个批次,每个分区都可以发送的数据。

小批量的批处理不那么常见,并可能降低吞吐量(批量大小为零将完全禁用批处理)。 非常大的批量大小可能会浪费内存,因此我们将总是分配预定额外记录的指定批量大小的缓冲器。

int16384[0,...]
client.id在发出请求时传递给服务器的id字符串。 这样做的目的是通过允许在服务器端请求记录中包括一个逻辑应用程序名称,能够跟踪超出ip / port的请求源。string"" 
connections.max.idle.ms在此配置指定的毫秒数后关闭空闲连接。long540000 

目录 2 - 标题 2

丢雷楼某 、、、

目录 3 - 标题 2

丢雷楼某 、、、