kafka消费命令简化(alias中传入参数)

今天药忘吃喽~ 2022-10-24 01:41 207阅读 0赞

我们常见的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的效率。**

**最終實驗效果如下**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2FwcGxleXVjaGk_size_16_color_FFFFFF_t_70][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2FwcGxleXVjaGk_size_16_color_FFFFFF_t_70]: /images/20221024/0ccaaf3afe1a4e4dbd97693a18e3a6ad.png