我们常见的kafka消费命令是这样的:

$KAFKA/bin/kafka-console-consumer.sh --bootstrap-server Desktop:9091 --from-beginning --topic user_behavior

显然我们希望能把上述命令行做成一个命令,并且能灵活接收user_behavior这样的topic参数

不然每次都需要去网上找一长串命令或者去翻阅自己的笔记,太麻烦。

我们想要下列形式:

consume 我的topic

这样的效果,避免寻找和粘贴复制一长串的命令,浪费时间.

################################################################################################################

下面是具体配置:

①当前语言,确保linux终端的默认语言是bash

appleyuchi@Desktop:~$ echo $SHELL
/usr/bin/bash

②/home/appleyuchi/scripts/kafka下面新建consume.sh

#!/bin/sh
$KAFKA/bin/kafka-console-consumer.sh --bootstrap-server Desktop:9091 --from-beginning --topic $1

新建produce.sh

#!/bin/sh
$KAFKA/bin/kafka-console-producer.sh --broker-list Desktop:9091 --topic $1

③~/.bashrc中的末尾加入

alias consume='function _blah(){ /home/appleyuchi/scripts/kafka/consume.sh $1;};_blah'
alias produce='function _blah(){ /home/appleyuchi/scripts/kafka/produce.sh $1;};_blah'

④另外新开个终端输入

consume user_behavior

这样,就可以避免输入本文开头长长的一大串命令,又可以把topic传入了,大大提高了调试kafka的效率。

最終實驗效果如下

kafka消费命令简化(alias中传入参数)相关推荐

  1. mysql存储过程或函数中传入参数与表字段名相同引发的悲剧

    真实案例.如下的一个存储过程: create procedure Apple(in user_id int) begin delete from users where user_id = user_ ...

  2. 向shell脚本中传入参数

    写一个 程序名为    test.sh    可带参数为 start 和 stop 执行  test.sh start 执行  start 内容的代码 执行 test.sh stop 执行 stop ...

  3. sql2008安装时提示参数不能为空_PHP命令行脚本接收传入参数的三种方式

    通常PHP都做http方式请求了,可以使用GET or POST方式接收参数,有些时候需要在shell命令下把PHP当作脚本执行,比如定时任务.这就涉及到在shell命令下如何给php传参的问题,通常 ...

  4. PHP命令行脚本接收传入参数的三种方式

    通常PHP都做http方式请求了,可以使用GET or POST方式接收参数,有些时候需要在shell命令下把PHP当作脚本执行,比如定时任务.这就涉及到在shell命令下如何给php传参的问题,通常 ...

  5. mybatis中传入参数的几种方式

    第一种: Dao层的方法 Public User selectUser(String name,String password); 对应的Mapper.xm <select id="s ...

  6. java main传入参数_Main方法中传入参数

    ↓ 这个时候会报错: Instantiate the class:DonutShop java.lang.ClassNotFoundException: DonutShop at java.net.U ...

  7. Linux下Ubuntu的常用压缩、解压缩命令,以及tar中的参数 cvf,xvf,cvzf,zxvf的区别

    .tar 文件(不压缩) # 仅打包,并非压缩 tar -xvf FileName.tar # 解包 tar -cvf FileName.tar DirName # 将DirName和其下所有文件(夹 ...

  8. VScode、argparse库、lauch.json中args参数

    argparse库是用于接受从command-lines传来参数的库,即argparse库接受命令台终端中传入的参数,但在VScode中并不需要从command-lines来配置参数.VScode通过 ...

  9. C#中 out 参数的使用

    当编写一个返回值较多且返回值均为同类型的方法时,可以考虑使用数组. 当一个方法需要返回多个类型不同的值时,宜使用out参数. Tips:在使用out参数时,不仅需要在方法的参数列表中传入参数(out ...

最新文章

  1. MOSS Single Sign On Setup Step-By-Step( 转)
  2. 开源中国源码学习笔记
  3. 项目管理理论与实践(4)——UML应用(上)
  4. 解决窗口属性兼容性问题的一些函数
  5. Documentum常见问题2—压力测试时一旦用户数超过一定数量就不能登录了
  6. oracle数值型转为char类型,PLSQL: Oracle函数to_char转化数字型指定小数点位数的技巧...
  7. 虚拟专题:联邦学习 | 面向隐私保护的非聚合式数据共享综述
  8. oracle语法_PG数据库sql语法总结,与Oracle有什么不同?
  9. jprofiler 9注册码
  10. Xcode中查看宏在预处理阶段的展开
  11. PMP考试需要准备什么教材呢?
  12. 施一公:无论什么学科,最不重要的就是智商
  13. matlab画区间柱状图,科学网—Matlab画柱状图 - 高淑敏的博文
  14. 指数函数 java_计算指数函数的算法
  15. 单播、广播、组播(多播)
  16. java解惑之最后的笑声
  17. 别让我们的幸福感受在别人眼中
  18. 我也DIY一个Android遥控器-全部开源
  19. 前端如何使用微信支付
  20. (七) 立创EDA之PCB设计示例

热门文章

  1. vue组件调用(用npm安装)
  2. Ambari 2.6.0 HDP 2.6.3集群搭建
  3. [Servlet]研究ServletContext对象
  4. 机器学习中防止过拟合方法
  5. hadoop NameNode HA 和ResouceManager HA
  6. 基于ArcGIS10.0和Oracle10g的空间数据管理平台(C#开发)-数据库设计
  7. C语言2011计算机二级c语言考点:c语言的基础知识
  8. Reflection.Emit的使用场景、工具包及示例总结
  9. 指令级并行--计算机体系结构
  10. php中MySQL数据库导入与导出_Mysql数据库导出和导入