惯性聚合 高效追踪和阅读你感兴趣的博客、新闻、科技资讯
阅读原文 在惯性聚合中打开

推荐订阅源

H
Hackread – Cybersecurity News, Data Breaches, AI and More
T
The Blog of Author Tim Ferriss
IT之家
IT之家
J
Java Code Geeks
C
Check Point Blog
F
Full Disclosure
B
Blog RSS Feed
Cyber Security Advisories - MS-ISAC
Cyber Security Advisories - MS-ISAC
freeCodeCamp Programming Tutorials: Python, JavaScript, Git & More
Engineering at Meta
Engineering at Meta
Recorded Future
Recorded Future
博客园 - 聂微东
Stack Overflow Blog
Stack Overflow Blog
M
MIT News - Artificial intelligence
大猫的无限游戏
大猫的无限游戏
让小产品的独立变现更简单 - ezindie.com
让小产品的独立变现更简单 - ezindie.com
奇客Solidot–传递最新科技情报
奇客Solidot–传递最新科技情报
月光博客
月光博客
The Cloudflare Blog
罗磊的独立博客
钛媒体:引领未来商业与生活新知
钛媒体:引领未来商业与生活新知
有赞技术团队
有赞技术团队
MongoDB | Blog
MongoDB | Blog
GbyAI
GbyAI
量子位
宝玉的分享
宝玉的分享
博客园 - 三生石上(FineUI控件)
F
Fortinet All Blogs
V
V2EX
人人都是产品经理
人人都是产品经理
A
About on SuperTechFans
D
Docker
MyScale Blog
MyScale Blog
P
Proofpoint News Feed
Blog — PlanetScale
Blog — PlanetScale
Recent Announcements
Recent Announcements
腾讯CDC
The GitHub Blog
The GitHub Blog
L
LangChain Blog
爱范儿
爱范儿
G
Google Developers Blog
OSCHINA 社区最新新闻
OSCHINA 社区最新新闻
阮一峰的网络日志
阮一峰的网络日志
U
Unit 42
酷 壳 – CoolShell
酷 壳 – CoolShell
博客园_首页
aimingoo的专栏
aimingoo的专栏
S
SegmentFault 最新的问题
Microsoft Security Blog
Microsoft Security Blog
V
Visual Studio Blog

Apache Kafka

Important configuration properties for the high-level consumer Kafka Configuration API Design API Design API Design API Design API Design API Design API Design Basic Kafka Operations Basic Kafka Operations Basic Kafka Operations Basic Kafka Operations Basic Kafka Operations Basic Kafka Operations Basic Kafka Operations Basic Kafka Operations Basic Kafka Operations Basic Kafka Operations Basic Kafka Operations Basic Kafka Operations Basic Kafka Operations Basic Kafka Operations Basic Kafka Operations Basic Kafka Operations Basic Kafka Operations Basic Kafka Operations Basic Kafka Operations Basic Kafka Operations Basic Kafka Operations Basic Kafka Operations Basic Kafka Operations Basic Kafka Operations Basic Kafka Operations Basic Kafka Operations Basic Kafka Operations Basic Kafka Operations Basic Kafka Operations Basic Kafka Operations Basic Kafka Operations Basic Kafka Operations Broker Configs Broker Configs Broker Configs Broker Configs Broker Configs Broker Configs Broker Configs Broker Configs Broker Configs Broker Configs Broker Configs Broker Configs Broker Configs Broker Configs Broker Configs Broker Configs Broker Configs Broker Configs Broker Configs Broker Configs Broker Configs Broker Configs Broker Configs Broker Configs Broker Configs Broker Configs Broker Configs Broker Configs Broker Configs Broker Configs Broker Configs Broker Configs Broker Configs Datacenters Design Design Design Design Design Design Design Design Design Design Design Design Design Design Design Design Design Design Design Design Design Design Design Design Design
Important configuration properties for Kafka broker
2001-01-01 · via Apache Kafka

You are viewing documentation for an older version (0.7) of Kafka. For up-to-date documentation, see the latest version.

Important configuration properties for Kafka broker

Important configuration properties for Kafka broker:

More details about server configuration can be found in the scala class kafka.server.KafkaConfig.

name

default

description

brokerid

none

Each broker is uniquely identified by an id. This id serves as the brokers “name”, and allows the broker to be moved to a different host/port without confusing consumers.

enable.zookeeper

true

enable zookeeper registration in the server

log.flush.interval

500

Controls the number of messages accumulated in each topic (partition) before the data is flushed to disk and made available to consumers.

log.default.flush.scheduler.interval.ms

3000

Controls the interval at which logs are checked to see if they need to be flushed to disk. A background thread will run at a frequency specified by this parameter and will check each log to see if it has exceeded its flush.interval time, and if so it will flush it.

log.default.flush.interval.ms

log.default.flush.scheduler.interval.ms

Controls the maximum time that a message in any topic is kept in memory before flushed to disk. The value only makes sense if it’s a multiple of log.default.flush.scheduler.interval .ms

topic.flush.intervals.ms

none

Per-topic overrides for log.default.flush.interval.ms. Controls the maximum time that a message in selected topics is kept in memory before flushed to disk. The per-topic value only makes sense if it’s a multiple of log.default.flush.scheduler.interval.ms. E.g., topic1:1000,topic2:2000

log.retention.hours

168

Controls how long a log file is retained.

topic.log.retention.hours

none

Topic-specific retention time that overrides log.retention.hours, e.g., topic1:10,topic2:20

log.retention.size

-1

the maximum size of the log before deleting it. This controls how large a log is allowed to grow

log.cleanup.interval.mins

10

Controls how often the log cleaner checks logs eligible for deletion. A log file is eligible for deletion if it hasn’t been modified for log.retention.hours hours.

log.dir

none

Specifies the root directory in which all log data is kept.

log.file.size

110241024*1024

Controls the maximum size of a single log file.

log.roll.hours

24 * 7

The maximum time before a new log segment is rolled out

max.socket.request.bytes

104857600

the maximum number of bytes in a socket request

monitoring.period.secs

600

the interval in which to measure performance statistics

num.threads

Runtime.getRuntime().availableProcessors

Controls the number of worker threads in the broker to serve requests.

num.partitions

1

Specifies the default number of partitions per topic.

socket.send.buffer

102400

the SO_SNDBUFF buffer of the socket sever sockets

socket.receive.buffer

102400

the SO_RCVBUFF buffer of the socket sever sockets

topic.partition.count.map

none

Override parameter to control the number of partitions for selected topics. E.g., topic1:10,topic2:20

zk.connect

localhost:2182/kafka

Specifies the zookeeper connection string in the form hostname:port/chroot. Here the chroot is a base directory which is prepended to all path operations (this effectively namespaces all kafka znodes to allow sharing with other applications on the same zookeeper cluster)

zk.connectiontimeout.ms

6000

Specifies the max time that the client waits to establish a connection to zookeeper.

zk.sessiontimeout.ms

6000

The zookeeper session timeout.

zk.synctime.ms

2000

Max time for how far a ZK follower can be behind a ZK leader