Jump To Close Expand all Collapse all Table of contents Kafka 配置调整 使开源包含更多 1. Kafka 调整概述 Expand section "1. Kafka 调整概述" Collapse section "1. Kafka 调整概述" 1.1. 映射属性和值 1.2. 有助于调整的工具 2. 受管代理配置 3. Kafka 代理配置调整 Expand section "3. Kafka 代理配置调整" Collapse section "3. Kafka 代理配置调整" 3.1. 基本代理配置 3.2. 为高可用性复制主题 3.3. 事务和提交的内部主题设置 3.4. 通过增加 I/O 线程改进请求处理吞吐量 3.5. 增加高延迟连接的带宽 3.6. 使用数据保留策略管理日志 3.7. 使用清理策略删除日志数据 3.8. 管理磁盘利用率 3.9. 处理大型消息大小 3.10. 控制消息数据的日志冲刷 3.11. 分区重新平衡可用性 3.12. unclean leader 选举机制 3.13. 避免不必要的消费者组重新平衡 4. Kafka 使用者配置调整 Expand section "4. Kafka 使用者配置调整" Collapse section "4. Kafka 使用者配置调整" 4.1. 基本消费者配置 4.2. 使用消费者组扩展数据消耗 4.3. 消息排序保证 4.4. 优化消费者进行吞吐量和延迟 4.5. 在提交偏移时避免数据丢失或重复 Expand section "4.5. 在提交偏移时避免数据丢失或重复" Collapse section "4.5. 在提交偏移时避免数据丢失或重复" 4.5.1. 控制事务消息 4.6. 恢复失败以避免数据丢失 4.7. 管理偏移策略 4.8. 最小化重新平衡的影响 5. Kafka 制作者配置调整 Expand section "5. Kafka 制作者配置调整" Collapse section "5. Kafka 制作者配置调整" 5.1. 基本制作者配置 5.2. 数据持久性 5.3. 排序交付 5.4. 可靠性保证 5.5. 优化制作者以实现吞吐量和延迟 A. 使用您的订阅 法律通告 Settings Close Language: 日本語 한국어 简体中文 English Language: 日本語 한국어 简体中文 English Format: Multi-page Single-page Format: Multi-page Single-page Language and Page Formatting Options Language: 日本語 한국어 简体中文 English Language: 日本語 한국어 简体中文 English Format: Multi-page Single-page Format: Multi-page Single-page 3.13. 避免不必要的消费者组重新平衡 对于加入新消费者组的消费者,您可以添加延迟,以避免对代理进行不必要的重新平衡: # ... group.initial.rebalance.delay.ms=3000 # ... 延迟是协调器等待成员加入的时间长度。延迟越长,很可能是所有成员将一次加入并避免重新平衡。但是,延迟也会阻止组消耗到周期结束为止。 Previous Next