我們常見的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中传入参数)的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。