创建主题:
./kafka-topics.sh --zookeeper localhost:12181 --create --topic lfwer --partitions 10 --replication-factor 2
增加主题分区数
./kafka-topics.sh --zookeeper localhost:12181 --alter --topic lfwer --partitions 10
删除主题
在server.properties中增加设置,默认未开启
delete.topic.enable=true
重启kafka
./kafka-server-stop.sh
./kafka-server-start.sh -daemon ../config/server.properties
执行删除
./kafka-topics.sh --zookeeper localhost:12181 --delete --topic lfwer
生产数据:
./kafka-console-producer.sh --topic lfwer --broker-list localhost:9092
消费数据:
./kafka-console-consumer.sh --topic lfwer --bootstrap-server localhost:9092
查看主题在分区中的偏移量 (time为-1时表示最大值,time为-2时表示最小值)
./kafka-run-class.sh kafka.tools.GetOffsetShell --topic lfwer --time -1 --broker-list localhost:9091 --partitions 0
查看有多少个组
./kafka-consumer-groups.sh --bootstrap-server localhost:9091 --list
查看组消费情况
./kafka-consumer-groups.sh --bootstrap-server localhost:9091 --describe --group my-group
相关推荐
赠送jar包:flink-connector-kafka_2.12-1.14.3.jar; 赠送原API文档:flink-connector-kafka_2.12-1.14.3-javadoc.jar; 赠送源代码:flink-connector-kafka_2.12-1.14.3-sources.jar; 赠送Maven依赖信息文件:...
赠送jar包:flink-connector-kafka_2.12-1.14.3.jar 赠送原API文档:flink-connector-kafka_2.12-1.14.3-javadoc.jar 赠送源代码:flink-connector-kafka_2.12-1.14.3-sources.jar 包含翻译后的API文档:flink-...
kafka_2.12-1.0.0.zip 2018最新版 包含自定义配置的kafka
最新版windows kafka_2.12-2.4.1.tgz
flink-connector-kafka_2.12-1.13.2.jar
Kafka 2.xx所有版本下载的百度网盘链接。包括: kafka_2.11-2.0.0.tgz, kafka_2.11-2.0.1.tgz, kafka_2.11-2.1.0.tgz, kafka_2.11-2.1.1.tgz, kafka_2.11-2.2.0.tgz, kafka_2.11-2.2.1.tgz, kafka_2.11-2.2.2.tgz, ...
Apache Kafka 2.8.1(Scala 2.12 :kafka_2.12-2.8.1.tgz) 是一个开源分布式事件流平台,被数千家公司用于高性能数据管道、流分析、数据集成和关键任务应用程序。) 是一个开源分布式事件流平台,被数千家公司用于高...
Apache Kafka 3.2.0 (Scala 2.12 :kafka_2.12-3.2.0.tgz) 是一个开源分布式事件流平台,被数千家公司用于高性能数据管道、流分析、数据集成和关键任务应用程序。) 是一个开源分布式事件流平台,被数千家公司用于高...
kafka安装包及安装步骤(原始安装及docker安装)
Kafka是一种高吞吐量的分布式发布订阅消息系统
最新版linux kafka_2.12-2.6.1.tgz最新版linux kafka_2.12-2.6.1.tgz
flink-connector-kafka_2.12-1.11.0.jar pylink链接kafka资源jar包f
最新版linux kafka_2.12-3.0.0.gz最新版linux kafka_2.12-3.0.0.gz
最新版kafka kafka_2.12-2.6.0.tgz
kafka_2.12-2.2.2版本,由于有时从官网下载比较慢,把kafka的安装包放上来,方便大家使用的时候,可以进行下载,在我的文章系列中,也有kafka在windows系统中的安装使用教程,可以具体查看
kafka_2.12-2.6.2.tgz亲测可用,参照:https://blog.csdn.net/oDengWei/article/details/119537383配置
kafka_2.12-3.2.0kafkakakakakakakakakakakakaka
kafka_2.12-1.0.0
kafka_2.12-2.3.0版本 kafka是一种高吞吐量的分布式发布订阅消息系统,她有如下特性: 通过O(1)的磁盘数据结构提供消息的持久化,这种结构对于即使数以TB的消息存储也能够保持长时间的稳定性能。 高吞吐量:即使是...