原创

Kafka基本操作

创建topic

kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic mytopic

查看topic

kafka-topics.sh --list --zookeeper localhost:2181

查看topic详情

kafka-topics.sh --describe --zookeeper localhost:2181 

producer生产消息

kafka-console-producer.sh --broker-list localhost:9092 --topic mytopic

consumer消费消息

kafka-console-consumer.sh   --bootstrap-server localhost:9092   --topic mytopic    --from-beginning

原创声明,本文系作者授权云+社区发表,未经许可,不得转载。

如有侵权,请联系 yunjia_community@tencent.com 删除。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • 用Kafka消费Flume传来的日志

    ZHANGHAO
  • Hive Metastore 使用MySQL存储

    Hive的metastore默认是存储在Derby数据库里面,只能用于单元测试,并且一次只能有一个进程连接到metastore的数据库。所以在实际的应用中,需要...

    ZHANGHAO
  • 实时MySQL数据源同步中间件-Maxwell

    Maxwell是一个读取MySQL binlog并将行更新作为JSON写入Kafka,Kinesis或其他流平台的应用程序。

    ZHANGHAO
  • 分布式消息队列Kafka

    Zookeeper:保存集群元数据和消费者信息,broker和主题元数据、消费者元数据分区偏移量

    凹谷
  • BigData-消息队列框架Apache Kafka入门、原理解析

    需要server.properties中设置delete.topic.enable=true否则只是标记删除。

    MiChong
  • SparkStreaming+Kafka 实现基于缓存的实时wordcount程序

    董可伦
  • Mybatis动态SQL示例

    <if> 不用我说的吧 <where> 可以帮你处理AND和OR的问题 (比如查询的时候) <set> 可以帮你处理逗号的问题(比如更新数据的时候) <trim...

    乐心湖
  • 常见分布1、泊松分布2、二项分布3、正态分布4、多项分布(二项分布推广)5、二维正态分布

    用户1733462
  • docker-comopose kafka 一键搭建

    本文是对使用Docker快速搭建Kafka开发环境的补充,跟随教程即可完成搭建,但还有些地方需要注意。

    平凡的学生族
  • 干货 | Flink Connector 深度解析

    作者介绍:董亭亭,快手大数据架构实时计算引擎团队负责人。目前负责 Flink 引擎在快手内的研发、应用以及周边子系统建设。2013 年毕业于大连理工大学,曾就职...

    暴走大数据

扫码关注云+社区

领取腾讯云代金券