您现在的位置是:首页 > 正文

初学kafka命令(topics)

2024-02-01 05:23:08阅读 3

创建kafka topic

bin/kafka-topics.sh --create --topic topicname --replication-factor 1 --partitions 1 --zookeeper localhost:2181

查询topic,进入kafka目录:

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

查询topic内容:

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topicName --from-beginning

往topics中写入数据

./bin/kafka-console-producer.sh --topic topicName --broker-list u210:9092


实际项目应用:

  • 调度项目kafka存储地址
/opt/cloudera/parcels/CDH-6.2.0-1.cdh6.2.0.p0.967373/lib/kafka$ 
  • 查看topic列表(zk是2181端口,broker是9092端口)
bin/kafka-topics.sh  --list --zookeeper ck234:2181/kafka 
  • kafka生产
bin/kafka-console-producer.sh --broker-list 10.9.20.234:9092 --topic kafka_spark
  • kafka消费
bin/kafka-console-consumer.sh  --bootstrap-server ck234:9092  --topic flink-kafka --group flinkmysql

网站文章

  • 【C语言】——打印杨辉三角(递归)

    【C语言】——打印杨辉三角(递归)

    觉得我分享的文章不错的话,可以关注一下哦,嘻嘻嘻🌞🌞

    2024-02-01 05:22:40
  • Java任务超时处理机制实现

    1问题描述 在应用软件的开发中,经常会遇到这样的一种需求:需要实现一个方法来执行某种任务,而这个方法的执行时间不能超过指定值,如果超时,则调用者不管这个方法将来是否可能执行成功,都要中断它的执行,或者让这个方法返回。这就是超时处理问题。 根据执行任务的方法是否异步,可以把问题从两个方面分析:如果方法顺序执行,则方法执行时整个程序的控制权在执行任务的方法中,方法调用者对于

    2024-02-01 05:22:33
  • 一个字节是几位?

    一个字节为8位。字节含义:字节是计算机信息技术用于计量存储容量的一种计量单位,也表示一些计算机编程语言中的数据类型和语言字符。数据存储是以“字节”(Byte)为单位,数据传输是以大多是以“位”(bit...

    2024-02-01 05:22:27
  • 【MATLAB】如何安装配置MinGW-w64 C/C++编译器 热门推荐

    【MATLAB】如何安装配置MinGW-w64 C/C++编译器 热门推荐

    【MATLAB】如何安装配置MinGW-w64 C/C++编译器 win10 + matlab2018b 具体方法: 1.打开你的matlab,选择“附加功能”,选择“获取附加功能” 2.在“附加功能...

    2024-02-01 05:22:00
  • 25.理一理关于tensorflow的各种骚操作

    1.tf.squeezehttps://www.jianshu.com/p/a21c0bc10a382.tf.casthttps://blog.csdn.net/dcrmg/article/details/797478143.tf.expand_dims https://www.cnblogs.com/helloworld0604/p/90017...

    2024-02-01 05:21:53
  • ‘mysql‘ 不是内部或外部命令,也不是可运行的程序或批处理文件终极大坑

    ‘mysql‘ 不是内部或外部命令,也不是可运行的程序或批处理文件终极大坑

    ‘mysql’ 不是内部或外部命令,也不是可运行的程序或批处理文件的解决方案‘mysql’ 不是内部或外部命令,也不是可运行的程序或批处理文件的解决方案,关于这个问题其实还是很好解决的,网上一搜全都有...

    2024-02-01 05:21:46
  • Python-Django篇----用Python搭建自己的服务(一)(2):配置文件介绍并运行本地服务

    Python-Django篇----用Python搭建自己的服务(一)(2):配置文件介绍并运行本地服务

    从这一篇文章开始呢,就涉及到代码的编写了,因为写的是Python嘛,所以建议大家去弄一个PyCharm,当然,也可以直接用命令行编写,我这里呢就用编译器方便介绍。 首先呢,我们看上篇文章中创建的项目文件, 主要呢我们就关心一下settings和urls文件就行了,wsgi就是个web服务的网端接口配置文件,我们不太care这东...

    2024-02-01 05:21:16
  • python 文件、文件夹详细操作

    python 文件、文件夹详细操作

    一、文件操作1、文件操作流程2、文件打开模式3、文件循环4、文件的修改5、flush方法6、whit语句7、其它操作二、文件夹 /1、提要2、判断路径或文件3、路径名、文件名分割4、工作目录及创建文件...

    2024-02-01 05:21:09
  • 【5G系列】Network Slicing学习总结(2)

    【5G系列】Network Slicing学习总结(2)

    Network Slicing种类

    2024-02-01 05:21:02
  • 写代码常见错误总结

    1. 同时使用' ' 和 " "的时候,一定不能全部用单引号或者全部用双引号。 2. xpath定位的时候,需要通过下面的方式,传参数进去: domainiptab...

    2024-02-01 05:20:55