【问题标题】:topic level overrides for Kafka topic do not workKafka 主题的主题级别覆盖不起作用
【发布时间】:2017-12-03 03:42:52
【问题描述】:

我为我的 Kafka 主题之一设置了多个主题级别覆盖,当我描述该主题时,我看到:

Topic:xxx PartitionCount:x ReplicationFactor:x Configs:segment.bytes=104857600,retention.ms=3600000,segment.ms=3600000

但是当我检查日志时,似乎没有遵循这些主题级别的配置。更具体地说,日志不是每小时滚动一次。我假设仍在使用代理配置,其中将 retention.ms/segment.ms 设置为 7 天,将 segment.bytes 设置为 1G。

【问题讨论】:

  • 您能描述一下您是如何为主题指定覆盖的吗?
  • @MickaelMaison 我正在使用脚本/opt/kafka/kafka_2.11-0.9.0.1/bin/kafka-topics.sh --alter --topic xxx --config segment.bytes=358300000 --zookeeper localhost:2181,还尝试使用雅虎的kafka-manager 来更新配置。
  • 您的意思是所有分区的日志都没有遵守这些设置吗?
  • @amethystic 是的

标签: apache-kafka


【解决方案1】:

在使用 Kafka 0.9.0 及更高版本时,您应该使用 kafka-configs.sh 脚本而不是 kafka-topics.sh

从 kafka-topics.sh 脚本更改主题配置 (kafka.admin.TopicCommand) 已被弃用。请继续前进 为此使用 kafka-configs.sh 脚本 (kafka.admin.ConfigCommand) 功能。

例如:

bin/kafka-configs.sh --zookeeper localhost:2181 --entity-type topics --entity-name my-topic --alter --add-config max.message.bytes=128000

Documentation

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 2021-02-05
    • 2016-01-10
    • 2023-02-24
    • 1970-01-01
    • 2011-01-23
    • 1970-01-01
    • 2019-02-28
    • 1970-01-01
    相关资源
    最近更新 更多