来源:/documentation.html#configuration
3. Configuration
Kafka在配置文件中使用key-value方式进行属性配置。这些values可以通过文件或者编程方式提供。
3.1 Broker Configs
基本配置如下:
-broker.id
-log.dirs
-zookeeper.connect
Topic-level配置以及其默认值将在下面讨论。
mit.timeout.ms 5000 offset commit的延迟时间,这和producer request的超时时间相似。
更多细节可以在scala 类 kafka.server.KafkaConfig中找到。
topic-level的配置
有关topics的配置既有全局的又有每个topic独有的配置。如果没有给定特定topic设置,则应用默认的全局设置。这些覆盖会在每次创建topic发生。下面的例子:创建一个topic,命名为my-topic,自定义最大消息尺寸以及刷新比率为:
> bin/kafka-topics.sh --zookeeper localhost:2181 --create --topic my-topic --partitions 1
--replication-factor 1 --config max.message.bytes=64000 --config flush.messages=1
需要删除重写时,可以按照以下来做:
> bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic my-topic
--deleteConfig max.message.bytes
以下是topic-level的配置选项。server的默认配置在Server Default Property列下给出了,设定这些默认值不会改变原有的设置
3.2 Consumer Configs
consumer基本配置如下:
group.id
zookeeper.connect
更多细节可以查看 scala类: kafka.consumer.ConsumerConfig
3.3 Producer Configs
producer基本的配置属性包含:
(1) metadata.broker.list
(2)request.required.acks
(3)producer.type
(4)serializer.class
更多细节需要查看 scala类
kafka.producer.ProducerConfig
3、4 New Producer Configs
我们正在努力替换现有的producer。代码在trunk中是可用的,可以认为beta版本。下面是新producer的配置