Kafka基本命令
2023-09-11 14:14:33 时间
1.创建自定义的topic
在bin目录下执行：
kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
注:副本数量要小于等于节点数量
2.查看所有的topic
kafka-topics.sh --list --zookeeper hostname:2181
3.启动producer
kafka-console-producer.sh --broker-list hostname:9092 --topic test
4.启动consumer
kafka-console-consumer.sh --bootstrap-server hostname:9092 --topic test --from-beginning
5.启动kafka
kafka-server-start.sh -daemon /opt/kafka_2.12-2.3.1/config/server.properties
6.删除topic指令：
进入bin目录，执行：
kafka-topics.sh --delete --zookeeper hadoop01:2181 --topic enbook
相关文章
- Kafka-控制器
- Kafka为什么性能这么快？
- Apache Kafka源码分析 - kafka controller
- 手把手教你 SpringBoot整合Kafka
- Kafka - kafka生产者 消费者 监听配置属性
- 真厉害，1 秒写入 10 万条消息，Kafka 写得这么快，都是因为这些优化。
- 一文理解Kafka如何消息不丢失
- Kafka如何修改分区Leader | 文末送书8本
- 【实战】kafka删除Topic常见异常排查思路及解决方案
- 【kafka源码】ReassignPartitionsCommand分区副本重分配源码原理分析(附配套教学视频)
- kafka可视化客户端工具（Kafka Tool）的基本使用
- Kafka实战：集群SSL加密认证和配置（最新版kafka-2.7.0）
- kafka最佳实践：Kafka Best Practices
- KSQL: Streaming SQL for Apache Kafka
- Kafka集成Kerberos之后如何使用生产者消费者命令
- kafka-rest：A Comprehensive, Open Source REST Proxy for Kafka
- java实时监听日志写入kafka（转）
- 漫游kafka实战篇之搭建Kafka开发环境