当前位置: 首页> 教育> 大学 > 建立网站小程序_短链接转换网站_谷歌商店paypal官网下载_营销型网站建设价格

建立网站小程序_短链接转换网站_谷歌商店paypal官网下载_营销型网站建设价格

时间:2025/7/11 12:08:43来源:https://blog.csdn.net/qq_43715111/article/details/147009625 浏览次数:0次
建立网站小程序_短链接转换网站_谷歌商店paypal官网下载_营销型网站建设价格
Kafka作为分布式流处理平台的核心组件,其主题管理是每个开发者必须掌握的关键技能。本文将详细解析kafka-topics.sh工具的使用技巧,从基础操作操作开始,助您轻松驾驭Kafka主题管理。

1 创建主题

/export/home/kafka_zk/kafka_2.13-2.7.1/bin/kafka-topics.sh --create \--bootstrap-server 192.168.10.33:9092 \--topic testtopic \--partitions 3 \--replication-factor 2
参数说明
  • --create:创建新主题
  • --bootstrap-server:指定Kafka服务器地址(格式为host:port)
  • --topic:要创建的主题名称
  • --partitions:主题的分区数量(决定并行度)
  • --replication-factor:副本因子(决定数据冗余度)
# 示例
[root@node6 bin]# /export/home/kafka_zk/kafka_2.13-2.7.1/bin/kafka-topics.sh --create \
>     --bootstrap-server 192.168.10.33:9092 \
>     --topic testtopic \
>     --partitions 3 \
>     --replication-factor 2
Created topic testtopic.
[root@node6 bin]# 

2 列出所有主题

/export/home/kafka_zk/kafka_2.13-2.7.1/bin/kafka-topics.sh --list \--bootstrap-server 192.168.10.33:9092
参数说明
  • --list:列出集群中所有可用主题
# 示例
[root@node6 bin]# /export/home/kafka_zk/kafka_2.13-2.7.1/bin/kafka-topics.sh --list \
>     --bootstrap-server 192.168.10.33:9092
__consumer_offsets
test_topic
testtopic
[root@node6 bin]# 

3 查看主题详情

/export/home/kafka_zk/kafka_2.13-2.7.1/bin/kafka-topics.sh --describe \--bootstrap-server 192.168.10.33:9092 \--topic testtopic
参数说明
  • --describe:显示主题的详细信息
  • --topic:指定要查看的主题
# 示例
[root@node6 bin]# /export/home/kafka_zk/kafka_2.13-2.7.1/bin/kafka-topics.sh --describe \
>     --bootstrap-server 192.168.10.33:9092 \
>     --topic testtopic
Topic: testtopic        PartitionCount: 3       ReplicationFactor: 2    Configs: compression.type=producer,min.insync.replicas=2,segment.jitter.ms=30000,cleanup.policy=delete,segment.bytes=1073741824,max.message.bytes=10485760,unclean.leader.election.enable=falseTopic: testtopic        Partition: 0    Leader: 1       Replicas: 1,2   Isr: 1,2Topic: testtopic        Partition: 1    Leader: 2       Replicas: 2,3   Isr: 2,3Topic: testtopic        Partition: 2    Leader: 3       Replicas: 3,1   Isr: 3,1
[root@node6 bin]# 

4 增加分区数

/export/home/kafka_zk/kafka_2.13-2.7.1/bin/kafka-topics.sh --alter \--bootstrap-server 192.168.10.33:9092 \--topic testtopic \--partitions 4
参数说明
  • --alter:修改主题配置
  • --partitions:新的分区数(注意:只能增加不能减少)
# 示例
[root@node6 bin]# /export/home/kafka_zk/kafka_2.13-2.7.1/bin/kafka-topics.sh --alter \
>     --bootstrap-server 192.168.10.33:9092 \
>     --topic testtopic \
>     --partitions 4
[root@node6 bin]#
[root@node6 bin]# /export/home/kafka_zk/kafka_2.13-2.7.1/bin/kafka-topics.sh --describe     --bootstrap-server 192.168.10.33:9092     --topic testtopic
Topic: testtopic        PartitionCount: 4       ReplicationFactor: 2    Configs: compression.type=producer,min.insync.replicas=2,segment.jitter.ms=30000,cleanup.policy=delete,segment.bytes=1073741824,max.message.bytes=10485760,unclean.leader.election.enable=falseTopic: testtopic        Partition: 0    Leader: 1       Replicas: 1,2   Isr: 1,2Topic: testtopic        Partition: 1    Leader: 2       Replicas: 2,3   Isr: 2,3Topic: testtopic        Partition: 2    Leader: 3       Replicas: 3,1   Isr: 3,1Topic: testtopic        Partition: 3    Leader: 1       Replicas: 1,3   Isr: 1,3
[root@node6 bin]# 

5 删除主题

/export/home/kafka_zk/kafka_2.13-2.7.1/bin/kafka-topics.sh --delete \--bootstrap-server 192.168.10.33:9092 \--topic testtopic
参数说明
  • --delete:删除指定主题(需确保 delete.topic.enable=true)
# 示例
[root@node6 bin]# /export/home/kafka_zk/kafka_2.13-2.7.1/bin/kafka-topics.sh --delete \
>     --bootstrap-server 192.168.10.33:9092 \
>     --topic testtopic
[root@node6 bin]# /export/home/kafka_zk/kafka_2.13-2.7.1/bin/kafka-topics.sh --list \
>     --bootstrap-server 192.168.10.33:9092
__consumer_offsets
test_topic
[root@node6 bin]# 
关键字:建立网站小程序_短链接转换网站_谷歌商店paypal官网下载_营销型网站建设价格

版权声明:

本网仅为发布的内容提供存储空间,不对发表、转载的内容提供任何形式的保证。凡本网注明“来源:XXX网络”的作品,均转载自其它媒体,著作权归作者所有,商业转载请联系作者获得授权,非商业转载请注明出处。

我们尊重并感谢每一位作者,均已注明文章来源和作者。如因作品内容、版权或其它问题,请及时与我们联系,联系邮箱:809451989@qq.com,投稿邮箱:809451989@qq.com

责任编辑: