<pre id="bdfbb"><ruby id="bdfbb"></ruby></pre>

    <pre id="bdfbb"><b id="bdfbb"></b></pre>

    <pre id="bdfbb"><del id="bdfbb"><mark id="bdfbb"></mark></del></pre>

          <p id="bdfbb"></p>
          <p id="bdfbb"><del id="bdfbb"><dfn id="bdfbb"></dfn></del></p>

          kafka修改刪除topic

          小編:管理員 12閱讀 2022.07.25

          You can change the configuration or partitioning of a topic using the same topic tool.
          你可以使用同樣的topic工具更改topic的配置和分區。

          To add partitions you can do
          你可以添加分區

          kafka版本 >= 2.2

          > bin/kafka-topics.sh --bootstrap-server broker_host:port --alter --topic my_topic_name         --partitions 40 

          kafka版本 < 2.2

          > bin/kafka-topics.sh --zookeeper zk_host:port/chroot --create --topic my_topic_name
                  --partitions 20 --replication-factor 3 --config x=y 

          Be aware that one use case for partitions is to semantically partition data, and adding partitions doesn't change the partitioning of existing data so this may disturb consumers if they rely on that partition. That is if data is partitionedbyhash(key) % number_of_partitionsthenthis partitioning will potentially be shuffled by adding partitions but Kafka will not attempt to automatically redistribute data in any way.
          要知道,一個用例的分區是語義上的分區數據,添加分區不能改變現有的數據,如果分區被使用中,這就可能會擾亂消費者。也就是說如果數據通過哈希(key)number_of_partitions劃分,那么該分區將通過添加分區進行洗牌,但kafka不以任何方式自動分配數據。

          添加配置:

          > bin/kafka-configs.sh --bootstrap-server broker_host:port --entity-type topics --entity-name my_topic_name --alter --add-config x=y 

          移除配置:

          > bin/kafka-configs.sh --bootstrap-server broker_host:port --entity-type topics --entity-name my_topic_name --alter --delete-config x 

          最后刪除主題:

          > bin/kafka-topics.sh --bootstrap-server broker_host:port --delete --topic my_topic_name

          Topic deletion option is disabled by default. To enable it set the server config
          topic刪除選項默認是關閉的,設置服務器配置開啟它。

          delete.topic.enable=true 

          Kafka does not currently support reducing the number of partitions for a topic or changing the replication factor.
          kafka目前不支持減少分區數和改變備份數,但是可以通過遷移腳本來實現。

          關聯標簽:
          国产 亚洲 中文 在线 字幕,99资源网,超碰国产97一区二区三区,无码中文人妻中文中文人妻
            <pre id="bdfbb"><ruby id="bdfbb"></ruby></pre>

            <pre id="bdfbb"><b id="bdfbb"></b></pre>

            <pre id="bdfbb"><del id="bdfbb"><mark id="bdfbb"></mark></del></pre>

                  <p id="bdfbb"></p>
                  <p id="bdfbb"><del id="bdfbb"><dfn id="bdfbb"></dfn></del></p>