代码之家  ›  专栏  ›  技术社区  ›  Colin Schofield

故障切换和恢复的最佳Kafka生产者选项

  •  2
  • Colin Schofield  · 技术社区  · 7 年前

    我想微调 KafkaTemplate

    我们有我们的 KafkaProducerMessageHandler 磨合 sync 模式(即等待发送操作结果- 请参阅: acks 注: 这在当前版本的卡夫卡中是必要的,以启用 报告。

    • acks = 1 经纪人负责人)
    • retries = 10
    • max.in.flight.requests.per.connection = 1 (如果达到错误状态,这将使消息保持有序)
    • linger.ms = 1 (不确定是否与此相关?)
    • request.timeout.ms = 5000 (超时5秒,这将与重试一起工作-因此 在消息被视为失败并随后出现在错误通道上之前,总时间为50秒)
    • enable.idempotence = false (再说一次,不确定这个选项?)
    • retry.backoff.ms = 100

    这些值听起来如何? 我有什么遗漏吗?

    1 回复  |  直到 7 年前
        1
  •  1
  •   codejitsu    7 年前

    这是一篇关于卡夫卡制作人调整的老帖子: http://ingest.tips/2015/07/19/tips-for-improving-performance-of-kafka-producer/

    TLDR版本: