kafka 配置topic

在Kafka中，可以通过使用kafka-topics.sh命令来配置topic。有几个操作可以进行配置，包括修改topic配置、创建topic时配置参数、删除topic级别配置参数等。

如果要修改现有topic的配置参数，可以使用以下命令：
bin/kafka-topics.sh --zookeeper 192.168.2.225:2183/config/mobile/mq/mafka02 --alter --topic my-topic --config max.message.bytes=128000 。这个命令会覆盖已经存在的topic参数，并将max.message.bytes属性设置为128000。

创建topic时配置参数可以通过以下命令实现：
bin/kafka-topics.sh --zookeeper 192.168.2.225:2183/config/mobile/mq/mafka02 --create --topic my-topic --partitions 1 --replication-factor 1 --config max.message.bytes=64000 --config flush.messages=1 。这个命令创建了一个名为"my-topic"的topic，并设置了两个参数，即max message size和flush rate。

如果想要删除topic级别的配置参数，可以使用以下命令：
bin/kafka-topics.sh --zookeeper 192.168.2.225:2183/config/mobile/mq/mafka02 --alter --topic my-topic --delete-config max.message.bytes 。这个命令会删除my-topic的max.message.bytes配置参数。

总结起来，Kafka中可以使用kafka-topics.sh命令对topic进行配置，包括修改已有配置、创建时配置和删除配置参数等操作。<span class="em">1</span><span class="em">2</span><span class="em">3</span>
#### 引用[.reference_title]
- *1* *2* *3* [Kafka的Topic配置详解](https://blog.csdn.net/wangshuminjava/article/details/109526288)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v93^chatsearchT3_2"}}] [.reference_item style="max-width: 100%"]
[ .reference_list ]