6.3 Kafka 配置

重要的客户端配置

最重要的老的 scala 版本的 producer 配置

• acks
• compression
• sync vs async production
• batch size (for async producers)

最重要的新的 Java 版本的 producer 配置

• acks
• compression
• batch size

最重要的 consumer 配置是 fetch size。

所有的配置请查阅 configuration 章节。

一个生产服务器配置

以下是生产服务器配置示例：

  # ZooKeeper
  zookeeper.connect=[list of ZooKeeper servers]

  # Log configuration
  num.partitions=8
  default.replication.factor=3
  log.dir=[List of directories. Kafka should have its own dedicated disk(s) or SSD(s).]

  # Other configurations
  broker.id=[An integer. Start with 0 and increment by 1 for each new broker.]
  listeners=[list of listeners]
  auto.create.topics.enable=false
  min.insync.replicas=2
  queued.max.requests=[number of concurrent requests]
  

我们的客户端配置在不同的使用场景下需要相应的变化。