1500字范文,内容丰富有趣,写作好帮手!
1500字范文 > kafka文档(3)---- 配置选项翻译

kafka文档(3)---- 配置选项翻译

时间:2019-02-02 08:05:55

相关推荐

kafka文档(3)---- 配置选项翻译

来源:/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的配置

本内容不代表本网观点和政治立场,如有侵犯你的权益请联系我们处理。
网友评论
网友评论仅供其表达个人看法,并不表明网站立场。